threading.Thread
Thread 是threading模塊中最重要的類之一,可以使用它來創建線程。有兩種方式來創建線程:一種是通過繼承Thread類,重寫它的run方法;另一種是創建一個threading.Thread對象,在它的初始化函數(__init__)中將可調用對象作為參數傳入。下面分別舉例說明。先來看看通過繼承threading.Thread類來創建線程的例子:
#coding=gbkimport threading, time, randomcount = 0class Counter(threading.Thread): def __init__(self, lock, threadName): '''@summary: 初始化對象。 @param lock: 瑣對象。 @param threadName: 線程名稱。 ''' super(Counter, self).__init__(name = threadName) #注意:一定要顯式的調用父類的初始化函數。 self.lock = lock def run(self): '''@summary: 重寫父類run方法,在線程啟動后執行該方法內的代碼。 ''' global count self.lock.acquire() for i in xrange(10000): count = count + 1 self.lock.release()lock = threading.Lock()for i in range(5): Counter(lock, "thread-" + str(i)).start()time.sleep(2) #確保線程都執行完畢print count
在代碼中,我們創建了一個Counter類,它繼承了threading.Thread。初始化函數接收兩個參數,一個是瑣對象,另一個是線程的名稱。在Counter中,重寫了從父類繼承的run方法,run方法將一個全局變量逐一的增加10000。在接下來的代碼中,創建了五個Counter對象,分別調用其start方法。最后打印結果。這里要說明一下run方法 和start方法: 它們都是從Thread繼承而來的,run()方法將在線程開啟后執行,可以把相關的邏輯寫到run方法中(通常把run方法稱為活動[Activity]。);start()方法用于啟動線程。
再看看另外一種創建線程的方法:
import threading, time, randomcount = 0lock = threading.Lock()def doAdd(): '''@summary: 將全局變量count 逐一的增加10000。 ''' global count, lock lock.acquire() for i in xrange(10000): count = count + 1 lock.release()for i in range(5): threading.Thread(target = doAdd, args = (), name = 'thread-' + str(i)).start()time.sleep(2) #確保線程都執行完畢print count
在這段代碼中,我們定義了方法doAdd,它將全局變量count 逐一的增加10000。然后創建了5個Thread對象,把函數對象doAdd 作為參數傳給它的初始化函數,再調用Thread對象的start方法,線程啟動后將執行doAdd函數。這里有必要介紹一下threading.Thread類的初始化函數原型:
def __init__(self, group=None, target=None, name=None, args=(), kwargs={})參數group是預留的,用于將來擴展; 參數target是一個可調用對象(也稱為活動[activity]),在線程啟動后執行; 參數name是線程的名字。默認值為“Thread-N“,N是一個數字。 參數args和kwargs分別表示調用target時的參數列表和關鍵字參數。
新聞熱點
疑難解答