python wait

import threading
import time

class ProducerConsumer:
    def __init__(self):
        self.condition = threading.Condition()
        self.data = []

    def produce(self):
        for i in range(5):
            with self.condition:
                self.data.append(i)
                print(f"Produced: {i}")
                self.condition.notify()  # 通知消费者
            time.sleep(1)

    def consume(self):
        while True:
            with self.condition:
                while not self.data:
                    self.condition.wait()  # 等待生产者通知
                item = self.data.pop(0)
                print(f"Consumed: {item}")

pc = ProducerConsumer()
producer_thread = threading.Thread(target=pc.produce)
consumer_thread = threading.Thread(target=pc.consume)

producer_thread.start()
consumer_thread.start()

producer_thread.join()
consumer_thread.join()