日韩久久久精品,亚洲精品久久久久久久久久久,亚洲欧美一区二区三区国产精品 ,一区二区福利

Python THREADING模塊中的JOIN()方法深入理解

系統 2573 0

看了oschina上的兩個代碼,受益匪淺。其中對join()方法不理解,看python官網文檔的介紹:
join([timeout]):等待直到進程結束。這將阻塞正在調用的線程,直到被調用join()方法的線程結束。(好難翻譯,應該是這個意思)

哈哈,這個易懂。
join方法,如果一個線程或者一個函數在執行過程中要調用另外一個線程,并且待到其完成以后才能接著執行,那么在調用這個線程時可以使用被調用線程的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
??? # 創建一個鎖
??? mutex = threading.Lock()
??? # 先創建線程對象
??? 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
??? # 創建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
??? # 創建鎖
??? mutex = threading.Lock()
??? # 創建線程對象
??? for x in xrange(0, num):
??????? threads.append(Test(10))
??? # 啟動線程
??? for t in threads:
??????? t.start()
??? # 等待子線程結束
??? for t in threads:
??????? t.join()

在程序中,最后join()方法的調用就明白了,是主進程挨個調用子線程的join()方法。當四個線程都執行完畢后,主線程才會執行下面的代碼,在這里也就是退出了。
相對應的在網上一起找到的另一個方法:
3.守護進程

setDaemon()

這個方法基本和join是相反的。當我們在程序運行中,執行一個主線程,如果主線程又創建一個子線程,主線程和子線程就分兵兩路,分別運行,那么當主線程完成想退出時,會檢驗子線程是否完成。如果子線程未完成,則主線程會等待子線程完成后再退出。但是有時候我們需要的是,只要主線程完成了,不管子線程是否完成,都要和主線程一起退出,這時就可以用setDaemon方法啦


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

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

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 类乌齐县| 古丈县| 金平| 达尔| 宝丰县| 泸定县| 从江县| 工布江达县| 新化县| 丰都县| 化州市| 北碚区| 临沂市| 固安县| 义马市| 保定市| 长汀县| 久治县| 缙云县| 武威市| 平湖市| 赣榆县| 永川市| 东乡| 准格尔旗| 连平县| 平昌县| 桐梓县| 南投县| 梁河县| 通化县| 鲜城| 平湖市| 梨树县| 卢湾区| 嵊泗县| 长顺县| 铅山县| 崇礼县| 台北市| 大余县|