Pythonday38事件

1 #通过一个信号 来控制 多个进程 同时 执行或者阻塞
2 #事件
3 from multiprocessing import Event
4 #一个信号可以使所有的进程都进入阻塞状态
5 #也可以控制所有的进程解除阻塞
6 #一个事件被创建之后&＃xff0c;默认是阻塞状态
7 e &＃61; Event() #创建了一个事件
8 print(e.is_set()) #查看一个事件的状态,默认被设置成阻塞
9 e.set() #将这个事情的状态改为True
10 print(e.is_set())
11 e.wait() #是依据e.is_set()的值来决定是阻塞的
12 print(123456)
13 e.clear() #将这个事件的状态改为False
14 print(e.is_set())
15 e.wait()
16 print(&＃39;*&＃39;*10)

1 import time
2 import random
3
4 from multiprocessing import Event,Process
5 def cars(e,i):
6 if not e.is_set():
7 print(&＃39;car%i在等待&＃39; % i)
8 e.wait() #阻塞 直到得到一个 事件状态变成True 的信号
9 print(&＃39;\033[0;32;40mcar%i通过\033[0m&＃39;%i)
10
11
12 def light(e):
13 while True:
14 if e.is_set():
15 e.clear()
16 print(&＃39;\033[31m红灯亮了\033[0m&＃39;)
17
18 else:
19 e.set()
20 print(&＃39;\033[32m绿灯亮了\033[0m&＃39;)
21 time.sleep(2)
22
23 if __name__ &＃61;&＃61; &＃39;__main__&＃39;:
24 e &＃61; Event()
25 traffic &＃61; Process(target&＃61;light,args&＃61;(e,))
26 traffic.start()
27 for i in range(20):
28 car &＃61; Process(target&＃61;cars, args&＃61;(e,i))
29 car.start()
30 time.sleep(random.random())