不废话，直接上四种模式，为方便大家复制，直接贴出代码

1、条件变量(Condition)方式，最复杂的一种

# 条件变量(Condition)：锁功能加入等待和唤醒功能，默认RLock# 两个线程用一个 cond 锁，手动唤醒和等待import timefrom threading import Threadfrom threading import Conditioncond = Condition()  # 两个线程共享一个锁num = 0def producer():  # 生产者线程    global num    with cond:        while True:            num += 1            print('生产1个，总数：{}'.format(num))            if num == 3:                print('已达到3个，不再生产')                time.sleep(3)                cond.notify()  # 循环 3 次，唤醒消费者线程                cond.wait()  # 释放锁，挂起生产者线程def customer():  # 消费者线程    global num    with cond:        while True:            num -= 1            print('消费了1个，剩余：{}'.format(num))            if num == 0:                print('已消费3个，唤醒生产者')                time.sleep(3)                cond.notify()  # 唤醒生产者线程                cond.wait()  # 释放锁，挂起消费者线程thd1 = Thread(target=producer)thd2 = Thread(target=customer)thd1.start()thd2.start()thd1.join()  # 线程同步-等子线程结束，主线程再继续运行thd2.join()  # 线程同步-等子线程结束，主线程再继续运行# 条件变量(Condition)的返回：# 连续返回："""生产1个，总数：1生产1个，总数：2生产1个，总数：3已达到3个，不再生产消费了1个，剩余：2消费了1个，剩余：1消费了1个，剩余：0已消费3个，唤醒生产者......"""

# 解释一下上面程序："""1、定义一个锁 con = Condition()，这个锁在两个线程中共享，只能一个线程运行2、先启动 thd1.start()，再启动 thd2.start()3、生产者线程先获得con锁，消费者线程遇到con锁，只能等待4、生产者在 con 锁内，循环3次，满足 if num == 3: 的条件5、用 con.notify() 唤醒其他线程(消费者线程)6、用 con.wait() 释放锁，并挂起当前线程(生产者线程)7、消费者线程 获得 con 锁，循环 3 次，满足 if num == 0: 的条件8、用 con.notify() 唤醒其他线程(生产者线程)9、用 con.wait() 释放锁，并挂起当前线程(消费者线程)再进行 4、5、6、7、8、9 步骤，反复用一个锁控制线程的唤醒和挂起"""

2、消息队列(queue)模式

# 生产者、消费者模型(边生产，边消费)from threading import Threadimport queuedef producter(que):    num = 0    while num < 3:        num += 1        que.put(num)        print('生产{}'.format(num))def customer(que):    while True:        data = que.get()        print('消费{}'.format(data))que = queue.Queue()t1 = Thread(target=producter,args=(que,))t2 = Thread(target=customer,args=(que,))t1.start()t2.start()# 打印返回：以下打印不一定按照顺序来的"""生产1生产2消费1生产3消费2消费3"""

3、协成方式(yield)

# 协程函数# 接收数据并处理def customer():    while True:        n = yield  # 接收生产者消息        print('消费：{}'.format(n))# 发送给生成器数据def producer(c):    c.send(None)  # 第一次启动生成器必须发送None，等价于 r = next(c)    for i in range(1,3):        print('生产：{}'.format(i))  # 生成器外部 接收生成器 多次返回出来的值        r = c.send(i)c = customer()producer(c)  # 两个函数产生关系。把生成器作为参数传入# 打印返回:"""生产：1消费：1生产：2消费：2"""