Python线程事件Event

今天来讲下Python线程事件Event的使用，Event的主要功能是用于线程间的通讯与同步。

Event有以下几种方法:

1. event.isSet()： 返回event的状态值；
2. event.wait()： 如果 event.isSet()==False将阻塞线程，event建立后默认为False；
3. event.set()： 设置event的状态值为True，所有阻塞池的线程激活进入就绪状态， 等待操作系统调度；
4. 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的方法，来自由和优雅的控制线程的启动或停止。