37.4-线程同步之Event

成熟与年龄无关，而是一种阅历；优雅与装扮无关，而是一种气度。不要期待别人能抚平自己的伤痛，只有把自己说服了，让自己想通了，才能彻底地根治心病。受挫、失误、不幸和磨难，是成长的催长素，也是成熟的催熟剂。我们不希望有痛苦，但也绝不能惧怕痛苦。唯有征服自己的人，才有能力去征服一切！

总结：

1. Python multiprocessing 多进程之间相互协调的方式有如下几种: Lock:锁,Queue:队列, Semaphore:信号量 ,Event:事件，Pipe:管道 ；
2. event：看状态的变化；使用同一个event对象；
3. 线程真正区别 是靠 线程ID；线程name;

1. 线程同步

概念
线程同步，线程间协同，通过某种技术，让一个线程访问某些数据时，其他线程不能访问这些数据，直到该线程完成对数据的操作。
不同操作系统实现技术有所不同，有临界区（Critical Section）、互斥量（Mutex）、信号量（Semaphore）、事件Event等

2. Event ***必须掌握

Event事件，是线程间通信机制中最简单的实现，使用一个内部的标记flag，通过flag的True或False的变化来进行操作。

Python 多进程中 Event 是用来实现进程间同步通信的(当然多线程中也可以用 event )。
事件event运行的机制是:全局定义了一个Flag，如果Flag值为 False，当程序执行event.wait()方法时就会阻塞，如果Flag值为True时，程序执行event.wait()方法时不会阻塞继续执行。

名称	含义
set()	标记设置为True
clear()	标记设置为False
is_set()	标记设置为True
wait(timeout=None)	设置等待标记为True ，None为无限等待；等待返回True,未等到超时了返回False

需求：老板雇佣了一个工人， 让他生产杯子，老板一直等着这个工人，直到生产10个杯子；

from threading import Event, Thread
import logging
import time

FORMAT = '%(asctime)s %(threadName)s %(thread)d %(message)s'
logging.basicConfig(format=FORMAT, level=logging.INFO)


def boss(event: Event):
    logging.info("I'm boss, waiting for U.")
    # 等待
    event.wait()   # 阻塞，等到返回True；
    logging.info("Good Job.")

def worker(event: Event, count=10):
    logging.info("I'm working for U.")
    cups = []
    while True:
        logging.info('make 1')

        time.sleep(0.5)
        cups.append(1)
        if len(cups) >= count:
            # 通知
            event.set()   # 变为 True;
            break
        logging.info('I finished my job. cups={}'.format(cups))

event = Event()
w = Thread(target=worker, args=(event,))
b = Thread(target=boss, args=(event,))
w.start()
b.start()
#---------------------------------------------------------------------------------------
2020-01-13 21:05:04,770 Thread-1 9660 I'm working for U.
2020-01-13 21:05:04,770 Thread-1 9660 make 1
2020-01-13 21:05:04,770 Thread-2 13696 I'm boss, waiting for U.
2020-01-13 21:05:05,272 Thread-1 9660 I finished my job. cups=[1]
2020-01-13 21:05:05,272 Thread-1 9660 make 1
2020-01-13 21:05:05,773 Thread-1 9660 I finished my job. cups=[1, 1]
2020-01-13 21:05:05,773 Thread-1 9660 make 1
2020-01-13 21:05:06,273 Thread-1 9660 I finished my job. cups=[1, 1, 1]
2020-01-13 21:05:06,273 Thread-1 9660 make 1
2020-01-13 21:05:06,774 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1]
2020-01-13 21:05:06,774 Thread-1 9660 make 1
2020-01-13 21:05:07,274 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1, 1]
2020-01-13 21:05:07,274 Thread-1 9660 make 1
2020-01-13 21:05:07,775 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1, 1, 1]
2020-01-13 21:05:07,775 Thread-1 9660 make 1
2020-01-13 21:05:08,276 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1, 1, 1, 1]
2020-01-13 21:05:08,276 Thread-1 9660 make 1
2020-01-13 21:05:08,776 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1, 1, 1, 1, 1]
2020-01-13 21:05:08,776 Thread-1 9660 make 1
2020-01-13 21:05:09,277 Thread-1 9660 I finished my job. cups=[1, 1, 1, 1, 1, 1, 1, 1, 1]
2020-01-13 21:05:09,277 Thread-1 9660 make 1
2020-01-13 21:05:09,778 Thread-2 13696 Good Job.

没有使用全局变量；

总结
使用同一个Event对象的标记flag。
谁wait就是等到flag变为True，或等到超时返回False。不限制等待的个数。

wait的使用

主线程wait到时间了 由False 变成True;结束主程序；

from threading import Event, Thread
import logging
logging.basicConfig(level=logging.INFO)

def do(event:Event,interval:int):
    while not event.wait(interval):
        logging.info('do sth')

e = Event()
Thread(target=do,args=(e,3)).start()

e.wait(10) # 也可以使用time.sleep(10)
e.set()
print('main exit')
#-----------------------------------------------------------------------
INFO:root:do sth
INFO:root:do sth
INFO:root:do sth
main exit

Event的wait优于time.sleep，它会更快的切换到其它线程，提高并发效率