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線程同步”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！