Python的多執行緒有兩種實現方法：

函式，執行緒類

1.函式

呼叫thread模組中的start_new_thread()函式來建立執行緒，以執行緒函式的形式告訴執行緒該做什麼

# -*- coding: utf-8 -*-
import thread
 
 
def f(name):
    #定義執行緒函式
    print "this is " + name
 
 
if __name__ == '__main__':
    thread.start_new_thread(f, ("thread1",))
    #用start_new_thread()呼叫執行緒函式和其他引數
    while 1:
        pass
 

不過這種方法暫時沒能找到其他輔助方法，連主執行緒等待都要用while 1這種方法解決。

2.執行緒類

呼叫threading模組，建立threading.Thread的子類來得到自定義執行緒類。

# -*- coding: utf-8 -*-
import threading
 
 
class Th(threading.Thread):
    def __init__(self, name):
        threading.Thread.__init__(self)
        self.t_name = name
        #呼叫父類建構函式
 
    def run(self):
        #重寫run()函式，執行緒預設從此函式開始執行
        print "This is " + self.t_name
 
if __name__ == '__main__':
    thread1 = Th("Thread_1")
    thread1.start()
    #start()函式啟動執行緒，自動執行run()函式
 

threading.Thread類的可繼承函式：

getName() 獲得執行緒物件名稱

setName() 設定執行緒物件名稱

join() 等待呼叫的執行緒結束後再執行之後的命令

setDaemon(bool) 阻塞模式，True：父執行緒不等待子執行緒結束，False 等待，預設為False

isDaemon() 判斷子執行緒是否和父執行緒一起結束，即setDaemon()設定的值

isAlive() 判斷執行緒是否在執行

例項

import threading
import time
 
 
class Th(threading.Thread):
    def __init__(self, thread_name):
        threading.Thread.__init__(self)
        self.setName(thread_name)
 
    def run(self):
        print "This is thread " + self.getName()
        for i in range(5):
            time.sleep(1)
            print str(i)
        print self.getName() + "is over"
 

join()阻塞等待

if __name__ == '__main__':
    thread1 = Th("T1 ")
    thread1.start()
    #thread1.join()
    print "main thread is over"

不帶thread1.join()，得到如下結果：

This is thread T1 

main thread is over

0

1

2

T1 is over

不等待thread1完成，執行之後語句。

加了thread1.join()，得到如下結果：

This is thread T1

0

1

2

T1 is over

main thread is over

阻塞等待thread1結束，才執行下面語句

主執行緒等待

if __name__ == '__main__':
    thread1 = Th("T1 ")
    thread1.setDaemon(True)
    #要線上程執行之前就設定這個量
    thread1.start()
    print "main thread is over"

報錯：Exception in thread T1  (most likely raised during interpreter shutdown):

也就是主執行緒不等待子執行緒就結束了。

多個子執行緒

if __name__ == '__main__':
    for i in range(3):
        t = Th(str(i))
        t.start()
    print "main thread is over"

這裡的t可同時處理多個執行緒，即t為執行緒控制代碼，重新賦值不影響執行緒。

這裡奇怪的是，執行t.run()時，不會再執行其他執行緒。雖不明，還是用start()吧。暫且理解為start()是非阻塞並行的，而run是阻塞的。

執行緒鎖

threading提供執行緒鎖，可以實現執行緒同步。

import threading
import time
 
 
class Th(threading.Thread):
    def __init__(self, thread_name):
        threading.Thread.__init__(self)
        self.setName(thread_name)
 
    def run(self):
        threadLock.acquire()
        #獲得鎖之後再執行
        print "This is thread " + self.getName()
        for i in range(3):
            time.sleep(1)
            print str(i)
        print self.getName() + " is over"
        threadLock.release()
        #釋放鎖
 
 
if __name__ == '__main__':
    threadLock = threading.Lock()
    #設定全域性鎖
    thread1 = Th('Thread_1')
    thread2 = Th('Thread_2')
    thread1.start()
    thread2.start()

得到結果：

This is thread Thread_1

0

1

2

Thread_1 is over

This is thread Thread_2

0

1

2

Thread_2 is over