python多线程之事件Event的使用详解

# coding:utf-8import threadingimport timeevent = threading.Event()def chihuoguo(name):  # 等待事件，进入等待阻塞状态  print '%s 已经启动' % threading.currentThread().getName()  print '小伙伴 %s 已经进入就餐状态！'%name  time.sleep(1)  event.wait()  # 收到事件后进入运行状态  print '%s 收到通知了.' % threading.currentThread().getName()  print '小伙伴 %s 开始吃咯！'%name# 设置线程组threads = []# 创建新线程thread1 = threading.Thread(target=chihuoguo, args=("a", ))thread2 = threading.Thread(target=chihuoguo, args=("b", ))# 添加到线程组threads.append(thread1)threads.append(thread2)# 开启线程for thread in threads:  thread.start()time.sleep(0.1)# 发送事件通知print '主线程通知小伙伴开吃咯！'event.set()

# coding:utf-8import threadingimport timeevent = threading.Event()def chiHuoGuo(name):  # 等待事件，进入等待阻塞状态  print '%s 已经启动' % threading.currentThread().getName()  print '小伙伴 %s 已经进入就餐状态！'%name  time.sleep(1)  event.wait()  # 收到事件后进入运行状态  print '%s 收到通知了.' % threading.currentThread().getName()  print '%s 小伙伴 %s 开始吃咯！'%(time.time(), name)class myThread (threading.Thread):  # 继承父类threading.Thread  def __init__(self, name):    '''重写threading.Thread初始化内容'''    threading.Thread.__init__(self)    self.people = name  def run(self):  # 把要执行的代码写到run函数里面 线程在创建后会直接运行run函数    '''重写run方法'''    chiHuoGuo(self.people)   # 执行任务    print("qq交流群：226296743")    print("结束线程: %s" % threading.currentThread().getName())# 设置线程组threads = []# 创建新线程thread1 = myThread("a")thread2 = myThread("b")thread3 = myThread("c")# 添加到线程组threads.append(thread1)threads.append(thread2)threads.append(thread3)# 开启线程for thread in threads:  thread.start()time.sleep(0.1)# 发送事件通知print '集合完毕，人员到齐了，开吃咯！'event.set()