成熟与年龄无关，而是一种阅历；优雅与装扮无关，而是一种气度。不要期待别人能抚平自己的伤痛，只有把自己说服了，让自己想通了，才能彻底地根治心病。受挫、失误、不幸和磨难，是成长的催长素，也是成熟的催熟剂。我们不希望有痛苦，但也绝不能惧怕痛苦。唯有征服自己的人，才有能力去征服一切！
总结：
- Python multiprocessing 多进程之间相互协调的方式有如下几种: Lock:锁,Queue:队列, Semaphore:信号量 ,Event:事件，Pipe:管道 ；
- event：看状态的变化；使用同一个event对象；
- 线程真正区别 是靠 线程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，它会更快的切换到其它线程，提高并发效率
网友评论