python threading線程同步怎么實(shí)現(xiàn)

本篇內(nèi)容主要講解“python threading線程同步怎么實(shí)現(xiàn)”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“python threading線程同步怎么實(shí)現(xiàn)”吧!

說明

1、threading模塊具有實(shí)現(xiàn)鎖定的內(nèi)置功能，允許同步線程。

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

2、可以調(diào)用Lock()方法來應(yīng)用鎖，它新的鎖對象。

可以調(diào)用鎖對象的獲取(阻塞)方法來強(qiáng)制線程同步運(yùn)行。

實(shí)例

#Python 多線程示例來演示鎖定。
#1. 使用 threading.Thread 類定義子類。
#2. 實(shí)例化子類并觸發(fā)線程。
#3. 在線程的 run 方法中實(shí)現(xiàn)鎖。
 
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 = []
 
# 創(chuàng)建新線程
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線程同步怎么實(shí)現(xiàn)”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！