如何利用NotifyAll实现线程同步

NotifyAll 是一种线程同步机制，用于在多个线程之间进行通信和协作

1. 导入所需库：

import threading import time 

2. 创建一个共享资源类，该类包含一个锁（Lock）对象和一个条件变量（Condition）对象。这将允许我们在多个线程之间同步对共享资源的访问。

class SharedResource:     def __init__(self):         self.lock = threading.Lock()         self.condition = threading.Condition(self.lock) 

3. 在共享资源类中添加一些方法来处理共享资源的状态更改。例如，我们可以添加一个方法来增加共享资源的值，并在值达到特定阈值时通知所有等待的线程。

class SharedResource:     # ... (previous code)      def increment_value(self):         with self.condition:             # Increment the shared resource's value             self.value += 1              # Check if the value has reached a specific threshold             if self.value >= self.threshold:                 # Notify all waiting threads                 self.condition.notify_all() 

4. 创建工作线程类，该类将执行特定任务并与共享资源交互。在此示例中，我们将创建一个线程，当共享资源的值达到阈值时，该线程将执行某个操作。

class WorkerThread(threading.Thread):     def __init__(self, shared_resource):         super().__init__()         self.shared_resource = shared_resource      def run(self):         with self.shared_resource.condition:             # Wait until the shared resource's value reaches the threshold             while self.shared_resource.value< self.shared_resource.threshold:                 self.shared_resource.condition.wait()              # Perform some action when the condition is met             print(f"Thread {self.name} is performing an action") 

5. 在主程序中创建共享资源对象、工作线程对象并启动线程。

def main():     shared_resource = SharedResource()      # Create and start worker threads     worker_threads = [WorkerThread(shared_resource) for _ in range(3)]     for thread in worker_threads:         thread.start()      # Increment the shared resource's value     for _ in range(10):         time.sleep(0.5)         shared_resource.increment_value()      # Wait for all worker threads to finish     for thread in worker_threads:         thread.join()  if __name__ == "__main__":     main() 

在这个示例中，我们使用 NotifyAll 方法通知所有等待的线程，共享资源的值已达到阈值。这样，当条件满足时，所有等待的线程都将被唤醒并执行相应的操作。