看了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()
|
新聞熱點
疑難解答