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()
方法等待计数器达到目标值。