歡迎您光臨本站 註冊首頁

淺談Python3多線程之間的執行順序問題

←手機掃碼閱讀     e36605 @ 2020-05-03 , reply:0

一個多線程的題:定義三個線程ID分別為ABC,每個線程打印10遍自己的線程ID,按ABCABC……的順序進行打印輸出。
我的解法:
from threading import Thread, Lock # 由_acquire解鎖執行後釋放_release鎖 def _print(_id: str, _acquire: Lock, _release: Lock) -> None: for i in range(10): _acquire.acquire() print(f"id:{_id}") _release.release() if __name__ == '__main__': # 創建三個鎖供3個線程使用 mutex1 = Lock() mutex2 = Lock() mutex3 = Lock() # 定義三個線程A、B、C # 線程A需要mutex1解鎖執行後釋放mutex2 # 線程B需要mutex2解鎖執行後釋放mutex3 # 線程C需要mutex3解鎖執行後釋放mutex1 # 元組中第一位是自定義的線程ID,第二位是解鎖需要的鎖,第三位是釋放的鎖 threads = [Thread(target=_print, args=[i[0], i[1], i[2]]) for i in [('A', mutex1, mutex2), ('B', mutex2, mutex3), ('C', mutex3, mutex1)]] # 把mutex2和mutex3這兩把鎖先用了以便阻塞線程2和線程3的執行 mutex2.acquire() mutex3.acquire() # 接下來只有線程A可以先執行是因為mutex1並沒有被佔用 # 線程B和線程C需要分別等待著鎖2和鎖3的釋放才能繼續執行 [thr.start() for thr in threads] [thr.join() for thr in threads]
補充知識:python線程執行代碼封裝和執行順序
線程-注意點
1. 線程執行代碼的封裝
通過上一小節,能夠看出,通過使用threading模塊能完成多任務的程序開發,為了讓每個線程的封裝性更完美,所以使用threading模塊時,往往會定義一個新的子類class,只要繼承threading.Thread就可以了,然後重寫run方法
示例如下:
#coding=utf-8 import threading import time class MyThread(threading.Thread): def run(self): for i in range(3): time.sleep(1) msg = "I'm "+self.name+' @ '+str(i) #name屬性中保存的是當前線程的名字 print(msg) if __name__ == '__main__': t = MyThread() t.start()
說明
python的threading.Thread類有一個run方法,用於定義線程的功能函數,可以在自己的線程類中覆蓋該方法。而創建自己的線程實例後,通過Thread類的start方法,可以啟動該線程,交給python虛擬機進行調度,當該線程獲得執行的機會時,就會調用run方法執行線程。
2. 線程的執行順序
#coding=utf-8 import threading import time class MyThread(threading.Thread): def run(self): for i in range(3): time.sleep(1) msg = "I'm "+self.name+' @ '+str(i) print(msg) def test(): for i in range(5): t = MyThread() t.start() if __name__ == '__main__': test()
執行結果:(運行的結果可能不一樣,但是大體是一致的)
I'm Thread-1 @ 0 I'm Thread-2 @ 0 I'm Thread-5 @ 0 I'm Thread-3 @ 0 I'm Thread-4 @ 0 I'm Thread-3 @ 1 I'm Thread-4 @ 1 I'm Thread-5 @ 1 I'm Thread-1 @ 1 I'm Thread-2 @ 1 I'm Thread-4 @ 2 I'm Thread-5 @ 2 I'm Thread-2 @ 2 I'm Thread-1 @ 2 I'm Thread-3 @ 2
說明
從代碼和執行結果我們可以看出,多線程程序的執行順序是不確定的。當執行到sleep語句時,線程將被阻塞(Blocked),到sleep結束後,線程進入就緒(Runnable)狀態,等待調度。而線程調度將自行選擇一個線程執行。上面的代碼中只能保證每個線程都運行完整個run函數,但是線程的啟動順序、run函數中每次循環的執行順序都不能確定。
3. 總結
每個線程默認有一個名字,儘管上面的例子中沒有指定線程對象的name,但是python會自動為線程指定一個名字。
當線程的run()方法結束時該線程完成。
無法控制線程調度程序,但可以通過別的方式來影響線程調度的方式。


[e36605 ] 淺談Python3多線程之間的執行順序問題已經有334次圍觀

http://coctec.com/docs/python/shhow-post-232657.html