Python中的wait()
函數主要用于線程同步。它用于讓當前線程暫停執行一段時間,直到其他線程完成某個操作或滿足某個條件。wait()
函數通常與線程的notify()
或notify_all()
方法一起使用,以實現線程間的協作。
wait()
函數的主要作用如下:
防止死鎖:當多個線程需要訪問共享資源時,如果沒有適當的同步機制,可能會導致死鎖。wait()
和notify()
/notify_all()
方法可以幫助避免這種情況。
控制線程執行順序:通過使用wait()
和notify()
/notify_all()
,可以控制線程的執行順序,確保某些線程在其他線程之前或之后執行。
實現線程間的通信:wait()
函數可以用于實現線程間的通信,讓一個線程等待另一個線程的信號,然后繼續執行。
下面是一個簡單的示例,展示了如何使用wait()
和notify()
方法:
import threading
class Counter:
def __init__(self):
self.value = 0
self.lock = threading.Lock()
self.condition = threading.Condition(self.lock)
def increment(self):
with self.condition:
self.value += 1
print(f"Value incremented to {self.value}")
self.condition.notify() # 通知等待的線程
def wait_for_value(self, target_value):
with self.condition:
while self.value < target_value:
self.condition.wait() # 等待線程通知
print(f"Target value {target_value} reached")
counter = Counter()
# 創建兩個線程,一個用于遞增計數器,另一個用于等待計數器達到目標值
t1 = threading.Thread(target=counter.increment)
t2 = threading.Thread(target=counter.wait_for_value, args=(5,))
t1.start()
t2.start()
t1.join()
t2.join()
在這個示例中,Counter
類使用了一個條件變量condition
來實現線程同步。increment()
方法在遞增計數器后調用notify()
方法,通知等待的線程。wait_for_value()
方法則使用wait()
方法等待計數器達到目標值。