【10.5】线程同步--conditon 使用以及源码分析

#!/user/bin/env python
# -*- coding:utf-8 -*-

# 条件变量，用于复杂的线程间同步
# 通过condition完成协同读诗
from threading import Lock
from threading import Condition
import threading


class XiaoAi(threading.Thread):
    def __init__(self, cond):
        super().__init__(name='小爱')
        self.cond = cond

    def run(self):
        with self.cond:
            # 等待
            self.cond.wait()
            print('{} : 在'.format(self.name))
            # 通知
            self.cond.notify()
            # 等待
            self.cond.wait()
            print('{} : 好啊'.format(self.name))
            # 通知
            self.cond.notify()


class TianMao(threading.Thread):
    def __init__(self, cond):
        super().__init__(name='天猫')
        self.cond = cond

    def run(self):
        # 建议使用with语句，不然acquire和release一定要成对出现
        with self.cond:
            print('{} : 小爱同学'.format(self.name))
            # 通知
            self.cond.notify()
            # 等待
            self.cond.wait()
            print('{} : 我们来对古诗吧'.format(self.name))
            # 通知
            self.cond.notify()
            # 等待
            self.cond.wait()


if __name__ == '__main__':
    cond = threading.Condition()
    xiao_ai = XiaoAi(cond)
    tian_mao = TianMao(cond)

    # 启动的先后顺序很重要
    # 在调用with方法，或者acquire方法之后，再调用wait和notify方法
    xiao_ai.start()
    tian_mao.start()

    # 先启动tian_mao，会打印出‘小爱同学’，但程序会‘死掉’，这是因为self.cond.notify()通知已经发出去了
    # 但是后面启动xiao_ai，xiao_ai的self.cond.wait()收不到通知。

天猫 : 小爱同学
小爱 : 在
天猫 : 我们来对古诗吧
小爱 : 好啊