簡要講解Python編程中線程的創建與鎖的使用

2019-11-25 16:54:40

字體：大中小

來源：轉載

供稿：網友

創建線程
創建線程的兩種方法：
1，直接調用threading.Thread來構造thread對象，Thread的參數如下：
class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})
group為None；
target為線程將要執行的功能函數；
name為線程的名字，也可以在對象構造后調用setName()來設定；
args為tuple類型的參數，可以為多個，如果只有一個也的使用tuple的形式傳入，例如(1,)；
kwargs為dict類型的參數，也即位命名參數
threading.Thread對象的其他方法：
start()，用來啟動線程；
join(), 等待直到線程結束；
isAlive(),獲取線程狀態

setDeamon(), 設置線程為deamon線程，必須在start()調用前調用，默認為非demon。
注意： python的主線程在沒有非deamon線程存在時就會退出。

threading.currentthread() , 用來獲得當前的線程；
threading.enumerate() ，用來多的當前存活的所有線程；

#coding:utf-8import threadingdef func1(num): for i in range(num):  #threading.currentThread()獲取當前線程，getName()獲取線程名字  print 'I am %s.num:%s' % (threading.currentThread().getName(), i)      def main(thread_num): thread_list = [] #定義一個線程列表 for i in range(thread_num):  thread_list.append(threading.Thread(target=func1, args = (3, ))) for a in thread_list:  #a.setDaemon(True)這個setDaemon默認為False 非守護線程  #表示主線程等所有子線程結束后，在結束  #設置為True的話 表示是個守護線程 子線程就會隨著主線程的結束而結束  #聽說服務監控工具生成的心跳線程 就是用的守護線程  a.start()             for a in thread_list:  a.join() #表示等待直到線程運行完畢      main(3)

運行結果

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    #把要執行的代碼寫到run函數里面 線程在創建后會直接運行run函數  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()

運行結果

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

鎖的使用
假設我們有一個公共數據x(也可以叫共享資源，臨界資源)，然后跑10個線程都去訪問這變量并對這個變量進行修改的操作，那么就得到意料之外的結果。

import threading       # 導入threading模塊import time        # 導入time模塊class mythread(threading.Thread):  # 通過繼承創建類 def __init__(self,threadname):  # 初始化方法  # 調用父類的初始化方法  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)   # 調用sleep函數，讓線程休眠5秒  print x                tl = []        # 定義列表for i in range(10): t = mythread(str(i))    # 類實例化 tl.append(t)      # 將類對象添加到列表中               x=0         # 將x賦值為0for i in tl: i.start()       # 依次運行線程

運行結果

[root@localhost ~]# python syn.py

30303030303030303030

由于x是全局變量（共享資源），每個線程對x操作后就休眠了
在線程休眠的時候其他線程也都開始執行操作，
最終休眠5秒后x的值最終就被修改為30了

使用互斥鎖來保護公共資源。用互斥鎖來保證同一時刻只有一個線程訪問公共資源,實現簡單的同步
互斥鎖：threading.Lock
互斥鎖方法：acquire() 獲取鎖 release():釋放鎖
當有一個線程獲的鎖之后，這把鎖就會進入locke狀態（被鎖起來了），另外的線程試圖獲取鎖的時候就會變成同步阻塞狀態，
當擁有線程鎖的的線程調用鎖方法 release()之后就會釋放鎖，那么鎖就會變成開鎖unlocked狀態，之后再從同步阻塞狀態的線程中選擇一個來獲得鎖

import threading       # 導入threading模塊import time        # 導入time模塊class mythread(threading.Thread):     # 通過繼承創建類 def __init__(self,threadname):     # 初始化方法  threading.Thread.__init__(self,name = threadname)  def run(self):       # 重載run方法  global x      # 使用global表明x為全局變量  lock.acquire()      # 調用lock的acquire方法  for i in range(3):   x = x + 1  time.sleep(2)   # 調用sleep函數，讓線程休眠5秒  print x  lock.release()    # 調用lock的release方法lock = threading.Lock()    # 類實例化tl = []       # 定義列表for i in range(10): t = mythread(str(i))   # 類實例化 tl.append(t)    # 將類對象添加到列表中       x=0      # 將x賦值為0for i in tl: i.start()      # 依次運行線程

運行結果：