条件变量基本示例

import threading

# 创建互斥锁和条件变量
mutex = threading.Lock()
condition = threading.Condition(mutex)

# 共享资源
shared_resource = []

# 生产者线程
def producer():
    global shared_resource

    # 获取互斥锁
    mutex.acquire()

    # 检查条件是否满足
    while len(shared_resource) >= 10:
        # 条件不满足，等待
        condition.wait()

    # 生产资源
    shared_resource.append("new_item")

    # 唤醒等待的消费者线程
    condition.notify()

    # 释放互斥锁
    mutex.release()

# 消费者线程
def consumer():
    global shared_resource

    # 获取互斥锁
    mutex.acquire()

    # 检查条件是否满足
    while len(shared_resource) == 0:
        # 条件不满足，等待
        condition.wait()

    # 消费资源
    item = shared_resource.pop()

    # 唤醒等待的生产者线程
    condition.notify()

    # 释放互斥锁
    mutex.release()

# 创建生产者和消费者线程
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

# 启动线程
producer_thread.start()
consumer_thread.start()

# 等待线程结束
producer_thread.join()
consumer_thread.join()