Python中協程Event()函數

python線程的事件用於主線程控制其他線程的執行，事件主要提供了三個方法wait、clear、set

事件處理的機制：全局定義了一個“Flag”，如果“Flag”值為 False，那么當程序執行 event.wait 方法時就會阻塞，如果“Flag”值為True，那么執行event.wait 方法時便不再阻塞。

• clear：將“Flag”設置為False
• set：將“Flag”設置為True

用 threading.Event 實現線程間通信，使用threading.Event可以使一個線程等待其他線程的通知，我們把這個Event傳遞到線程對象中，

Event默認內置了一個標志，初始值為False。一旦該線程通過wait()方法進入等待狀態，直到另一個線程調用該Event的set()方法將內置標志設置為True時，該Event會通知所有等待狀態的線程恢復運行。

#!/usr/bin/python3
#_*_ coding: UTF-8 _*_


import threading, time
import random

def light():
    if not event.isSet():
        event.set()  #wait就不阻塞 #綠燈狀態
    count = 0
    i=0
    while True:
        if count <10:
            print("---green light on ---")
        elif count<13:
            print("---yellow light on ---")
        elif count <20:
            if event.isSet():
                event.clear()
            print("---red light on ---")
        else:
            count = 0
            event.set()#打開綠燈
        time.sleep(1)
        count +=1
        i+=1
        if(i>20):
            break
def car(n):
    i=0
    while 1:
        time.sleep(random.randrange(3))
        if event.isSet():#如果是綠燈
            print("car [%s] is running.."%n)
        else:
            print("car [%s] is waiting for the red light.."%n)
        if(i>10):
            break
        else:
            i+=1
        
if __name__ == '__main__':
    event = threading.Event()
    Light = threading.Thread(target=light)
    Light.start()
    for i in range(3):
        t = threading.Thread(target=car,args=(i,))
        t.start()