python threading線程同步怎么實現

本篇內容主要講解“python threading線程同步怎么實現”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“python threading線程同步怎么實現”吧!

說明

1、threading模塊具有實現鎖定的內置功能，允許同步線程。

為了防止數據損壞或丟失，需要鎖定來控制共享資源的訪問。

2、可以調用Lock()方法來應用鎖，它新的鎖對象。

可以調用鎖對象的獲取(阻塞)方法來強制線程同步運行。

實例

#Python 多線程示例來演示鎖定。
#1. 使用 threading.Thread 類定義子類。
#2. 實例化子類并觸發線程。
#3. 在線程的 run 方法中實現鎖。
 
import threading
import datetime
 
exitFlag = 0
 
class myThread (threading.Thread):
    def __init__(self, name, counter):
        threading.Thread.__init__(self)
        self.threadID = counter
        self.name = name
        self.counter = counter
    def run(self):
        print("\nStarting " + self.name)
        # 獲取鎖同步線程
        threadLock.acquire()
        print_date(self.name, self.counter)
        # 為下一個線程釋放鎖
        threadLock.release()
        print("Exiting " + self.name)
 
def print_date(threadName, counter):
    datefields = []
    today = datetime.date.today()
    datefields.append(today)
    print("{}[{}]: {}".format( threadName, counter, datefields[0] ))
 
threadLock = threading.Lock()
threads = []
 
# 創建新線程
thread1 = myThread("Thread", 1)
thread2 = myThread("Thread", 2)
 
# 啟動新線程
thread1.start()
thread2.start()
 
# 添加線程到線程列表
threads.append(thread1)
threads.append(thread2)
 
# 等待所有線程完成
for thread in threads:
    thread.join()
 
print("\nExiting the Program!!!")

到此，相信大家對“python threading線程同步怎么實現”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！