創(chuàng)建線程
創(chuàng)建線程的兩種方法：
1，直接調(diào)用threading.Thread來構(gòu)造thread對象，Thread的參數(shù)如下：
class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})
group為None；
target為線程將要執(zhí)行的功能函數(shù)；
name為線程的名字，也可以在對象構(gòu)造后調(diào)用setName()來設(shè)定；
args為tuple類型的參數(shù)，可以為多個(gè)，如果只有一個(gè)也的使用tuple的形式傳入，例如(1,)；
kwargs為dict類型的參數(shù)，也即位命名參數(shù)
threading.Thread對象的其他方法：
start()，用來啟動(dòng)線程；
join(), 等待直到線程結(jié)束；
isAlive(),獲取線程狀態(tài)
setDeamon(), 設(shè)置線程為deamon線程，必須在start()調(diào)用前調(diào)用，默認(rèn)為非demon。
注意： python的主線程在沒有非deamon線程存在時(shí)就會(huì)退出。
threading.currentthread() , 用來獲得當(dāng)前的線程；
threading.enumerate() ， 用來多的當(dāng)前存活的所有線程；
#coding:utf-8import threadingdef func1(num): for i in range(num): #threading.currentThread()獲取當(dāng)前線程，getName()獲取線程名字 print 'I am %s.num:%s' % (threading.currentThread().getName(), i) def main(thread_num): thread_list = [] #定義一個(gè)線程列表 for i in range(thread_num): thread_list.append(threading.Thread(target=func1, args = (3, ))) for a in thread_list: #a.setDaemon(True)這個(gè)setDaemon默認(rèn)為False 非守護(hù)線程 #表示主線程等所有子線程結(jié)束后，在結(jié)束 #設(shè)置為True的話 表示是個(gè)守護(hù)線程 子線程就會(huì)隨著主線程的結(jié)束而結(jié)束 #聽說服務(wù)監(jiān)控工具生成的心跳線程 就是用的守護(hù)線程 a.start() for a in thread_list: a.join() #表示等待直到線程運(yùn)行完畢 main(3)
運(yùn)行結(jié)果
I am Thread-1.num:0I am Thread-1.num:1I am Thread-1.num:2I am Thread-2.num:0I am Thread-2.num:1I am Thread-2.num:2I am Thread-3.num:0I am Thread-3.num:1I am Thread-3.num:2
2，直接從threading.Thread繼承，然后重寫__init__方法和run方法
#coding:utf-8import threadingclass MyThread(threading.Thread): #繼承父類threading.Thread def __init__(self, num ): threading.Thread.__init__(self) self.num = num #把要執(zhí)行的代碼寫到run函數(shù)里面 線程在創(chuàng)建后會(huì)直接運(yùn)行run函數(shù) def run(self): for i in range(self.num): print 'I am %s.num:%s' % (self.getName(), i) for i in range(3): t = MyThread(3) t.start() t.join()
運(yùn)行結(jié)果
I am Thread-1.num:0I am Thread-1.num:1I am Thread-1.num:2I am Thread-2.num:0I am Thread-2.num:1I am Thread-2.num:2I am Thread-3.num:0I am Thread-3.num:1I am Thread-3.num:2
鎖的使用
假設(shè)我們有一個(gè)公共數(shù)據(jù)x(也可以叫共享資源，臨界資源)，然后跑10個(gè)線程都去訪問這變量并對這個(gè)變量進(jìn)行修改的操作，那么就得到意料之外的結(jié)果。
import threading # 導(dǎo)入threading模塊import time # 導(dǎo)入time模塊class mythread(threading.Thread): # 通過繼承創(chuàng)建類 def __init__(self,threadname): # 初始化方法 # 調(diào)用父類的初始化方法 threading.Thread.__init__(self,name = threadname) def run(self): # 重載run方法 global x # 使用global表明x為全局變量 for i in range(3): x = x + 1 time.sleep(2) # 調(diào)用sleep函數(shù)，讓線程休眠5秒 print x tl = [] # 定義列表for i in range(10): t = mythread(str(i)) # 類實(shí)例化 tl.append(t) # 將類對象添加到列表中 x=0 # 將x賦值為0for i in tl: i.start() # 依次運(yùn)行線程
運(yùn)行結(jié)果
[root@localhost ~]# python syn.py
30303030303030303030
由于x是全局變量（共享資源），每個(gè)線程對x操作后就休眠了
在線程休眠的時(shí)候其他線程也都開始執(zhí)行操作，
最終休眠5秒后x的值最終就被修改為30了
使用互斥鎖來保護(hù)公共資源。用互斥鎖來保證同一時(shí)刻只有一個(gè)線程訪問公共資源,實(shí)現(xiàn)簡單的同步
互斥鎖：threading.Lock
互斥鎖方法：acquire() 獲取鎖 release():釋放鎖
當(dāng)有一個(gè)線程獲的鎖之后，這把鎖就會(huì)進(jìn)入locke狀態(tài)（被鎖起來了），另外的線程試圖獲取鎖的時(shí)候就會(huì)變成同步阻塞狀態(tài)，
當(dāng)擁有線程鎖的的線程調(diào)用鎖方法 release()之后就會(huì)釋放鎖，那么鎖就會(huì)變成開鎖unlocked狀態(tài)，之后再從同步阻塞狀態(tài)的線程中選擇一個(gè)來獲得鎖
import threading # 導(dǎo)入threading模塊import time # 導(dǎo)入time模塊class mythread(threading.Thread): # 通過繼承創(chuàng)建類 def __init__(self,threadname): # 初始化方法 threading.Thread.__init__(self,name = threadname) def run(self): # 重載run方法 global x # 使用global表明x為全局變量 lock.acquire() # 調(diào)用lock的acquire方法 for i in range(3): x = x + 1 time.sleep(2) # 調(diào)用sleep函數(shù)，讓線程休眠5秒 print x lock.release() # 調(diào)用lock的release方法lock = threading.Lock() # 類實(shí)例化tl = [] # 定義列表for i in range(10): t = mythread(str(i)) # 類實(shí)例化 tl.append(t) # 將類對象添加到列表中 x=0 # 將x賦值為0for i in tl: i.start() # 依次運(yùn)行線程
運(yùn)行結(jié)果：
[root@localhost ~]# python syn.py
36912151821242730
可重入鎖：threading.RLock()
方法和互斥鎖一樣。
假設(shè)一個(gè)鎖嵌套的情況：有個(gè)線程以及獲取到鎖和共享資源了，但是又需要一把鎖來獲取另外一個(gè)資源，那么只要把代碼里面的：
lock = threading.Lock()
修改為：
lock = threading.RLock()
