# !usr/bin/env python
# -*- coding:utf-8 _*-
"""
@Author:何以解忧
@Blog(个人博客地址): shuopython.com
@WeChat Official Account(微信公众号)：猿说python
@Github:www.github.com@File:python_.py
@Time:2019/10/21 21:25@Motto:不积跬步无以至千里，不积小流无以成江海，程序人生的精彩需要坚持不懈地积累！
"""# 导入线程模块
import threading# 创建条件变量condition
con = threading.Condition()def thread_one(name):# 条件变量condition 线程上锁con.acquire()print("{}:成语接龙准备好了吗".format(name))# 唤醒正在等待(wait)的线程con.notify()# 等待对方回应消息，使用wait阻塞线程，等待对方通过notify唤醒本线程con.wait()print("{}:一干二净".format(name))# 唤醒对方con.notify()# 等待消息答应con.wait()print("{}:一天就知道看抖音美女，给你来个简单点的，来了：毛手毛脚".format(name))# 唤醒对方con.notify()# 等待消息答应con.wait()print("{}:哟哟哟，不错不错！".format(name))# 唤醒对方con.notify()# 条件变量condition 线程释放锁con.release()def thread_two(name):# 条件变量condition 线程上锁con.acquire()# wait阻塞状态，等待其他线程通过notify唤醒本线程con.wait()print("{}:准备好了~开始吧！".format(name))# 唤醒对方con.notify()# 等待消息答应con.wait()print("{}:净你妹啊，没法接...来个简单点的...".format(name))# 唤醒对方con.notify()# 等待消息答应con.wait()print("{}:嘿,这个我知道：脚踏实地".format(name))# 唤醒对方con.notify()con.release()if __name__ == "__main__":# 创建并初始化线程t1 = threading.Thread(target=thread_one,args=("A"))t2 = threading.Thread(target=thread_two,args=("B"))# 启动线程 -- 注意线程启动顺序，启动顺序很重要t2.start()t1.start()# 阻塞主线程，等待子线程结束t1.join()t2.join()print("程序结束！")

A:成语接龙准备好了吗
B:准备好了~开始吧！
A:一干二净
B:净你妹啊，没法接...来个简单点的...
A:一天就知道看抖音美女，给你来个简单点的，来了：毛手毛脚
B:嘿,这个我知道：脚踏实地
A:哟哟哟，不错不错！
程序结束！

# 导入线程模块
import threading
import time# 创建条件变量condition
con = threading.Condition()
meat_num = 0def thread_consumers():# 条件变量condition 线程上锁con.acquire()# 全局变量声明关键字 globalglobal meat_nummeat_num = 0# 等待肉片下锅煮熟con.wait()while True:print("我来一块肉片...")meat_num -= 1print("剩余肉片数量：%d"%meat_num)time.sleep(0.5)if meat_num == 0:# 肉片吃光了，通知老板添加肉片print("老板，再来一份老肉片...")con.notify()# 肉片吃光了，等待肉片con.wait()# 条件变量condition 线程释放锁con.release()def thread_producer():# 条件变量condition 线程上锁con.acquire()# 全局变量声明关键字 globalglobal meat_num# 肉片熟了，可以开始吃了meat_num = 10print("肉片熟了，可以开始吃了...")con.notify()while True:# 阻塞函数,等待肉片吃完的通知con.wait()meat_num = 10# 添加肉片完成，可以继续开吃print("添加肉片成功！当前肉片数量：%d"%meat_num)time.sleep(1)con.notify()con.release()if __name__ == "__main__":# 创建并初始化线程t1 = threading.Thread(target=thread_producer)t2 = threading.Thread(target=thread_consumers)# 启动线程 -- 注意线程启动顺序，启动顺序很重要t2.start()t1.start()# 阻塞主线程，等待子线程结束t1.join()t2.join()print("程序结束！")

肉片熟了，可以开始吃了...
我来一块肉片...
剩余肉片数量：9
我来一块肉片...
剩余肉片数量：8
我来一块肉片...
剩余肉片数量：7
我来一块肉片...
剩余肉片数量：6
我来一块肉片...
剩余肉片数量：5
我来一块肉片...
剩余肉片数量：4
我来一块肉片...
剩余肉片数量：3
我来一块肉片...
剩余肉片数量：2
我来一块肉片...
剩余肉片数量：1
我来一块肉片...
剩余肉片数量：0
老板，再来一份老肉片...
添加肉片成功！当前肉片数量：10
我来一块肉片...
剩余肉片数量：9
我来一块肉片...
剩余肉片数量：8
我来一块肉片...
剩余肉片数量：7
.............