Posted on 2007-12-26 18:04
江邊之鳥(niǎo) 閱讀(10208)
評(píng)論(1) 編輯 收藏 引用 所屬分類(lèi):
python
python是支持多線(xiàn)程的，并且是native的線(xiàn)程。主要是通過(guò)thread和threading這兩個(gè)模塊來(lái)實(shí)現(xiàn)的。thread是比較底層的模
塊，threading是對(duì)thread做了一些包裝的，可以更加方便的被使用。這里需要提一下的是python對(duì)線(xiàn)程的支持還不夠完善，不能利用多
CPU，但是下個(gè)版本的python中已經(jīng)考慮改進(jìn)這點(diǎn)，讓我們拭目以待吧。
threading模塊里面主要是對(duì)一些線(xiàn)程的操作對(duì)象化了，創(chuàng)建了叫Thread的class。一般來(lái)說(shuō)，使用線(xiàn)程有兩種模式，一種是創(chuàng)建線(xiàn)程要執(zhí)行的
函數(shù)，把這個(gè)函數(shù)傳遞進(jìn)Thread對(duì)象里，讓它來(lái)執(zhí)行；另一種是直接從Thread繼承，創(chuàng)建一個(gè)新的class，把線(xiàn)程執(zhí)行的代碼放到這個(gè)新的
class里。我們來(lái)看看這兩種做法吧。
#-*- encoding: gb2312 -*-
import string, threading, time
def thread_main(a):
global count, mutex
# 獲得線(xiàn)程名
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)建一個(gè)鎖
mutex = threading.Lock()
# 先創(chuàng)建線(xiàn)程對(duì)象
for x in xrange(0, num):
threads.append(threading.Thread(target=thread_main, args=(10,)))
# 啟動(dòng)所有線(xiàn)程
for t in threads:
t.start()
# 主線(xiàn)程中等待所有子線(xiàn)程退出
for t in threads:
t.join()
if __name__ == '__main__':
num = 4
# 創(chuàng)建4個(gè)線(xiàn)程
main(4)
上面的就是第一種做法，這種做法是很常見(jiàn)的，下面是另一種，曾經(jīng)使用過(guò)Java的朋友應(yīng)該很熟悉這種模式：
#-*- 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)建線(xiàn)程對(duì)象
for x in xrange(0, num):
threads.append(Test(10))
# 啟動(dòng)線(xiàn)程
for t in threads:
t.start()
# 等待子線(xiàn)程結(jié)束
for t in threads:
t.join()