Python多线程如何实现条件变量 Python多线程复杂同步机制详解

import threading
import time
import random
<h1>共享资源</h1><p>items = []
condition = threading.Condition()</p><p>def producer():
global items
for i in range(5):
condition.acquire()
item = random.randint(1, 100)
items.append(item)
print(f"生产者: 添加 {item}")
condition.notify()  # 唤醒一个消费者
condition.release()
time.sleep(1)</p><p>def consumer():
global items
while True:
condition.acquire()
if not items:
print("消费者: 暂无数据，等待...")
condition.wait()  # 释放锁并等待
item = items.pop(0)
print(f"消费者: 取出 {item}")
condition.release()
time.sleep(2)</p><h1>启动线程</h1><p>t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer)</p><p>t1.start()
t2.start()</p><p>t1.join()
t2.join()</p>

def consumer_with():
    global items
    while True:
        with condition:
            if not items:
                print("等待新数据...")
                condition.wait()
            item = items.pop(0)
            print(f"消费: {item}")
        time.sleep(2)  # 不在锁内休眠，提高并发性

with condition:
    while not some_condition:
        condition.wait()
    # 执行操作
    do_something()