今天来讲下Python线程事件Event的使用，Event的主要功能是用于线程间的通讯与同步。
Event有以下几种方法:
- event.isSet()： 返回event的状态值；
- event.wait()： 如果 event.isSet()==False将阻塞线程，event建立后默认为False；
- event.set()： 设置event的状态值为True，所有阻塞池的线程激活进入就绪状态， 等待操作系统调度；
- event.clear()： 恢复event的状态值为False。
下面我们通过一个实际的例子，来说明Event事件的用法：
这个例子中，我们模拟了一个交通灯和车辆通行的场景。
一个主线程，负责信号灯，Event事件来模拟信号灯的红绿灯切换。
两个子线程负责模拟两量车，并接收Event事件的切换做相应的动作。
范例1：
from threading import Thread,Event
import time
event=Event()
def light():
print('红灯正亮着')
time.sleep(3)
event.set() #绿灯亮
def car(name):
print('车%s正在等绿灯' %name)
event.wait() #等灯绿 此时event为False,直到event.set()将其值设置为True,才会继续运行.
print('车%s通行' %name)
if __name__ == '__main__':
# 红绿灯
light=Thread(target=light)
light.start()
# car1
car1=Thread(target=car,args=(1,))
car1.start()
# car2
car2=Thread(target=car,args=(2,))
car2.start()
通过这个简单的例子，我们已经掌握了Event事件的主要功能，接下来的例子里，我们演示下同一线程中Event的应用。我们使用Event功能来实现线程的暂停，恢复与停止。
范例2：
import threading
import time
class Job(threading.Thread):
def __init__(self, *args, **kwargs):
super(Job, self).__init__(*args, **kwargs)
self.__flag = threading.Event() # 用于暂停线程的标识
self.__flag.set() # 设置为True
self.__running = threading.Event() # 用于停止线程的标识
self.__running.set() # 将running设置为True
self.__result = False
def get_result(self):
""" 获取请求结果 """
if self.__result:
return self.__result
def run(self):
while self.__running.isSet():
self.__flag.wait() # 为True时立即返回, 为False时阻塞直到内部的标识位为True后返回
print (time.time())
time.sleep(1)
self.__result = True
def pause(self):
self.__flag.clear() # 设置为False, 让线程阻塞
def resume(self):
self.__flag.set() # 设置为True, 让线程停止阻塞
def stop(self):
self.__flag.set() # 将线程从暂停状态恢复, 如何已经暂停的话
self.__running.clear() # 设置为False
if __name__ == '__main__':
a = Job()
a.start()
time.sleep(3)
a.pause()
time.sleep(3)
a.resume()
time.sleep(3)
a.pause()
time.sleep(2)
print(a.get_result())
a.stop()
总结，event其本质可以理解为一个跨线程的全局变量，我们可以利用其wait()和set()以及clear()的方法，实现线程间或线程内的通讯与同步。实际工作中，我们也经常会使用类似于范例2的方法，来自由和优雅的控制线程的启动或停止。
