簡要講解Python編程中線程的創(chuàng)建與鎖的使用

這篇文章主要介紹了簡要講解Python編程中線程的創(chuàng)建與鎖的使用,Python中雖然有GIL的存在,但依然是能夠創(chuàng)建多個(gè)線程來交替使用的,

創(chuàng)建線程
創(chuàng)建線程的兩種方法：
1，直接調(diào)用threading.Thread來構(gòu)造thread對(duì)象，Thread的參數(shù)如下：
class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})
group為None；
target為線程將要執(zhí)行的功能函數(shù)；
name為線程的名字，也可以在對(duì)象構(gòu)造后調(diào)用setName()來設(shè)定；
args為tuple類型的參數(shù)，可以為多個(gè)，如果只有一個(gè)也的使用tuple的形式傳入，例如(1,)；
kwargs為dict類型的參數(shù)，也即位命名參數(shù)
threading.Thread對(duì)象的其他方法：
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)前存活的所有線程；    

運(yùn)行結(jié)果    
I am Thread-1.num:0
I am Thread-1.num:1
I am Thread-1.num:2
I am Thread-2.num:0
I am Thread-2.num:1
I am Thread-2.num:2
I am Thread-3.num:0
I am Thread-3.num:1
I am Thread-3.num:2

2，直接從threading.Thread繼承，然后重寫__init__方法和run方法    
#coding:utf-8
import threading
class 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:0
I am Thread-1.num:1
I am Thread-1.num:2
I am Thread-2.num:0
I am Thread-2.num:1
I am Thread-2.num:2
I am Thread-3.num:0
I am Thread-3.num:1
I am Thread-3.num:2


鎖的使用
假設(shè)我們有一個(gè)公共數(shù)據(jù)x(也可以叫共享資源，臨界資源)，然后跑10個(gè)線程都去訪問這變量并對(duì)這個(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)      # 將類對(duì)象添加到列表中
                
x=0         # 將x賦值為0
for i in tl:
 i.start()       # 依次運(yùn)行線程

                                                       
運(yùn)行結(jié)果    
[root@localhost ~]# python syn.py
    
30
30
30
30
30
30
30
30
30
30

由于x是全局變量（共享資源），每個(gè)線程對(duì)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)    # 將類對(duì)象添加到列表中
        
x=0      # 將x賦值為0
for i in tl:
 i.start()      # 依次運(yùn)行線程

                          
運(yùn)行結(jié)果：    
[root@localhost ~]# python syn.py    
3
6
9
12
15
18
21
24
27
30

可重入鎖：threading.RLock()
方法和互斥鎖一樣。
假設(shè)一個(gè)鎖嵌套的情況：有個(gè)線程以及獲取到鎖和共享資源了，但是又需要一把鎖來獲取另外一個(gè)資源，那么只要把代碼里面的：    
lock = threading.Lock()
修改為：    
lock = threading.RLock()