python的多執行緒（整理總結）

本篇文章給大家帶來了關於Python的相關知識，其中主要介紹了關於多執行緒的相關內容，多個執行緒可以在同一個程式中執行，並且每一個執行緒完成不同的任務，下面一起來看一下，希望對大家有幫助。

程式設計師必備介面測試偵錯工具：

python多執行緒

一、執行緒的概念

執行緒是CPU分配資源的基本單位。當一程式開始執行，這個程式就變成了一個程序，而一個程序相當於一個或者多個執行緒。當沒有多執行緒程式設計時，一個程序相當於一個主執行緒；當有多執行緒程式設計時，一個程序包含多個執行緒（含主執行緒）。使用執行緒可以實現程式大的開發。

多個執行緒可以在同一個程式中執行，並且每一個執行緒完成不同的任務。

多執行緒實現後臺服務程式可以同時處理多個任務，並不發生阻塞現象。

多執行緒的程式設計的特點就是能夠提高程式執行效率和處理速度。python程式可以同時並行執行多個相對獨立的執行緒。

二、建立多執行緒

python支援兩種建立多執行緒的方式：

~通過 threading.Thread () 建立。

~通過繼承 threading.Thread 類的繼承。

1.通過 threading.Thread () 建立

語法形式：

thread.Thread(group=Nore,targt=None,args=(),kwargs={},*,daemon=None)
登入後複製

引數解釋：

~group：必須為None，於ThreadGroup類相關，一般不使用。

~target：執行緒呼叫的物件，就是目標函數。

~name：為執行緒起這個名字。預設是Tread-x，x是序號，由1開始，第一個建立的執行緒名字就是Tread-1。

~args：為目標函數傳遞關鍵字引數，字典。

~daemon：用來設定執行緒是否隨主執行緒退出而退出。

範例：

import threading
def test (x,y):
 for i in range(x,y):
   print(i)
thread1 = threading.Thread(name='t1',target= test,args=(1,10))
thread2 = threading.Thread(name='t2',target= test,args=(11,20))
thread1.start()   #啟動執行緒1
thread2.start()   #啟動執行緒2
登入後複製

輸出：

解釋：兩個程式會並行執行，所以結果不一定每次都是順序的1~10，這是根據CPU給兩個執行緒風馬分配的時間片段來決定。可以看到每次結果都不同。

2.通過繼承 threading.Thread 類的繼承

threading.Thread是一個類，可以繼承它。

範例：

import threading
class mythread(threading.Thread):
  def run(self):
    for i in range(1,10):
      print(i)
thread1 = mythread();
thread2 = mythread();
thread1.start()
thread2.start()
登入後複製

輸出：

解釋：自定義一個類繼承threading.Thread,然後重寫父類別的run方法，執行緒啟動時（執行start（））會自動執行該方法。

三、主執行緒

在python中，主執行緒是第一個啟動的執行緒。

~父執行緒:如果啟動執行緒A中啟動了一個執行緒B，A就是B的父執行緒。

~子執行緒：B就是A的子執行緒。

建立執行緒時有一個damon屬性，用它來判斷主執行緒。當daemon設定False時，執行緒不會隨主執行緒退出而退出，主執行緒會一直等著子執行緒執行完;。當daemon設定True時，執行緒會隨主執行緒退出而退出，主執行緒結束其他的子執行緒會強制退出。

使用daemon注意：

~daemon屬性必須在start( )之前設定，否則會引發RuntimeError異常

~每個執行緒都由daemon屬性，可以顯示設定也可以不設定，不設定則取預設值None

~如果子子執行緒不設定daemon屬性，就取當前執行緒的daemon來設定它。子子執行緒繼承子執行緒的daemon值，作用和設定None一樣。

~從主執行緒建立的所有執行緒不設定daemon屬性，則預設都是daemon=False。

範例：

import time
import threading
def test():
 time.sleep(10)
 for i in range(10):
  print(i)
thread1 = threading.Thread(target=test,daemon=False)
thread1.start()
print('主執行緒完成了')
登入後複製

輸出：

主執行緒完成了
0
1
2
3
4
5
6
7
8
9
登入後複製

解釋：當主執行緒執行完畢輸出完之後，等待一下後輸出0~9。如果將daemon=False該為daemon=True，則不會執行for i in range(10)語句。

四、阻塞執行緒

一個執行緒中呼叫另一個執行緒的join方法，呼叫者被阻塞，直到呼叫執行緒被終止。

語法形式：

join(timeout-=None)
登入後複製

timeout 引數指定呼叫者等待多久，沒有設定時，就一直等待被呼叫執行緒結束被呼叫執行緒結束。其中，一個執行緒可以被join多次呼叫。

範例：

import time
import threading
def test():
 time.sleep(5)
 for i in range(10):
  print(i)
thread1=threading.Thread(target=test)
thread1.start()
thread1.join()
print('主執行緒完成了')
登入後複製

輸出：

0
1
2
3
4
5
6
7
8
9
主執行緒完成了
登入後複製

解釋：在thread1.start()後加thread1.join()新增join方法，輸出時，主執行緒就會等待輸出完0~9後再執行自己的print輸出。

五、判斷執行緒是否活動的

~run（）：用以表示執行緒活動的方法

~start（）：啟動執行緒

~join（）：等待至執行緒終止

~isAlive（）：返回執行緒是否活動的

~getName（）：返回執行緒名稱

~setName() : 設定執行緒名稱

範例：

from threading import Thread, Event
import time
def countdown(n, started_evt):
    print('正在執行')
    started_evt.set()
    while n > 0:
        print('時間', n)
        n -= 1
        time.sleep(2)
started_evt = Event()
print('開始倒計時')
t = Thread(target=countdown, args=(10, started_evt))
t.start()
started_evt.wait()
print('倒計時執行')
登入後複製

輸出：

開始倒計時
正在執行
時間 10
倒計時執行
時間 9
時間 8
時間 7
時間 6
時間 5
時間 4
時間 3
時間 2
時間 1
登入後複製

Alive，顧名思義，它表示執行緒當前是否為可用狀態，如果執行緒已經啟動，並且當前沒有任何異常的話，則返回true，否則為false

Thread.isAlive() ：顧名思義，是表示當前執行緒時候為可用狀態，即是否已經在啟動，並且在執行的狀態；

六、執行緒同步

1.同步概念

非同步模式的情況下，同時有一個執行緒在修改共用資料，另一個執行緒在讀取共用資料，當修改的共用資料的執行緒沒有處理完畢，讀取資料的執行緒肯定會得到錯誤的結果。如果採用多執行緒的同步控制機制，當處理共用資料的執行緒完成處理資料之後，讀取執行緒就讀取資料。

python的鎖就解決這一問題，鎖住執行緒，只允許一個執行緒操作，其他執行緒排隊等待，待當前執行緒操作完畢後，再按順序一個一個來執行。

2. python的鎖

python的threading模組提供了RLock鎖解決方法。在某一時間只能讓一個執行緒操作的語句放到RLock的acquire方法和release方法之間，即acquire相當於給RLack上鎖，而release相當於解鎖。

範例：

import threading
class mythread(threading.Thread):
 def run(self):
  global x                   #宣告一個全域性變數
  lock.acquire()             #上鎖
  x +=10
  print('%s:%d'%(self.name,x))
  lock.release()             #解鎖
x = 0                        #設定全域性變數初始值
lock = threading.RLock()     #建立可重入鎖
list1 = []                   
for i in range(5):   
 list1.append(mythread())    #建立五個執行緒，放到同一列表中
for i in list1:
 i.start()                   #開啟列表執行緒
登入後複製

輸出：

Thread-1:10
Thread-2:20
Thread-3:30
Thread-4:40
Thread-5:50
登入後複製

解釋：

3. python中的條件鎖

條件鎖常用的方法：

~acquire([timeout]):呼叫關聯鎖的方法

~release()：解鎖

~wait():使執行緒進入 Condition 的等待池等待通知並釋放解鎖。使用前執行緒必須已獲得鎖定，否則將丟擲異常。

~notify():從等待池挑選一個執行緒並通知，收到通知的執行緒將自動呼叫 acquire() 嘗試獲得，其他執行緒仍然在等待池中等待通知，直到該執行緒收到通知呼叫該方法，否則將會丟擲異常。

~notify ALL():跟notify() 一樣，但這個方法對應的是所有的執行緒。

範例：

題目：有幾個生產車間生產，幾個消費者購買，當生產達到一定數量時，停止生產。

import threading
import time
condtion = threading.Condition()
sheep = ['1件產品','1件產品','1件產品','1件產品','1件產品']
class Producer(threading.Thread):
    def __init__(self, name):
        super().__init__(name=name)
        pass
    def run(self):
        global condtion, sheep
        while True:
            time.sleep(0.1)
            condtion.acquire()
            if len(sheep) < 10:
                print(self.name + "生產了1件產品")
                sheep.append('1件產品')
                condtion.notifyAll()
                pass
            else:
                print("倉庫滿了，停止生產!")
                condtion.wait()
                pass
            condtion.release()
        pass
    pass
class Customer(threading.Thread):
    def __init__(self, name):
        super().__init__(name=name)
        pass
    def run(self):
        global condtion, sheep
        while True:
            time.sleep(0.1)
            condtion.acquire()
            if len(sheep) > 0:
                meat = sheep.pop()
                print(self.name + "購買了" + meat + "還剩多少" + str(len(sheep)) + "件")
                condtion.notifyAll()
                pass
            else:
                print("買光了，等待")
                condtion.wait()
                pass
            condtion.release()
        pass
    pass
if __name__ == "__main__":
    p1 = Producer("1號生產車間")
    p2 = Producer("2號生產車間")
    p3 = Producer("3號生產車間")
    p4 = Producer("4號生產車間")
    p5 = Producer("5號生產車間")
    p6 = Producer("6號生產車間")
    p1.start()
    p2.start()
    p4.start()
    p5.start()
    p6.start()
    c1 = Customer('小王')
    c2 = Customer('小李')
    c3 = Customer('小賈')
    c4 = Customer('小沈')
    c5 = Customer('小劉')
    c1.start()
    c2.start()
    c3.start()
    c4.start()
    c5.start()
登入後複製

【相關推薦：Python3視訊教學】

以上就是python的多執行緒（整理總結）的詳細內容，更多請關注TW511.COM其它相關文章！