看了oschina上的兩個代碼,受益匪淺。其中對join()方法不理解,看python官網文檔的介紹:
join([timeout]):等待直到進程結束。這將阻塞正在調用的線程,直到被調用join()方法的線程結束。(好難翻譯,應該是這個意思)
哈哈,這個易懂。
join方法,如果一個線程或者一個函數在執(zhí)行過程中要調用另外一個線程,并且待到其完成以后才能接著執(zhí)行,那么在調用這個線程時可以使用被調用線程的join方法。
#-*- encoding: gb2312 -*-
import string, threading, time
?
def thread_main(a):
??? global count, mutex
??? # 獲得線程名
??? threadname = threading.currentThread().getName()
?
??? for x in xrange(0, int(a)):
??????? # 取得鎖
??????? mutex.acquire()
??????? count = count + 1
??????? # 釋放鎖
??????? mutex.release()
??????? print threadname, x, count
??????? time.sleep(1)
?
def main(num):
??? global count, mutex
??? threads = []
?
??? count = 1
??? # 創(chuàng)建一個鎖
??? mutex = threading.Lock()
??? # 先創(chuàng)建線程對象
??? for x in xrange(0, num):
??????? threads.append(threading.Thread(target=thread_main, args=(10,)))
??? # 啟動所有線程
??? for t in threads:
??????? t.start()
??? # 主線程中等待所有子線程退出
??? for t in threads:
??????? t.join()?
?
if __name__ == '__main__':
??? num = 4
??? # 創(chuàng)建4個線程
??? main(4)
###################################################################
#-*- encoding: gb2312 -*-
import threading
import time
?
class Test(threading.Thread):
??? def __init__(self, num):
??????? threading.Thread.__init__(self)
??????? self._run_num = num
?
??? def run(self):
??????? global count, mutex
??????? threadname = threading.currentThread().getName()
?
??????? for x in xrange(0, int(self._run_num)):
??????????? mutex.acquire()
??????????? count = count + 1
??????????? mutex.release()
??????????? print threadname, x, count
??????????? time.sleep(1)
?
if __name__ == '__main__':
??? global count, mutex
??? threads = []
??? num = 4
??? count = 1
??? # 創(chuàng)建鎖
??? mutex = threading.Lock()
??? # 創(chuàng)建線程對象
??? for x in xrange(0, num):
??????? threads.append(Test(10))
??? # 啟動線程
??? for t in threads:
??????? t.start()
??? # 等待子線程結束
??? for t in threads:
??????? t.join()
在程序中,最后join()方法的調用就明白了,是主進程挨個調用子線程的join()方法。當四個線程都執(zhí)行完畢后,主線程才會執(zhí)行下面的代碼,在這里也就是退出了。
相對應的在網上一起找到的另一個方法:
3.守護進程
setDaemon()
這個方法基本和join是相反的。當我們在程序運行中,執(zhí)行一個主線程,如果主線程又創(chuàng)建一個子線程,主線程和子線程就分兵兩路,分別運行,那么當主線程完成想退出時,會檢驗子線程是否完成。如果子線程未完成,則主線程會等待子線程完成后再退出。但是有時候我們需要的是,只要主線程完成了,不管子線程是否完成,都要和主線程一起退出,這時就可以用setDaemon方法啦
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
