python 多线程 事件event(并行编程 7)

a.wait() b.wait() c.wait() /// set() //all start()

coding:utf-8

import threading import time

event = 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()

Thread-1 已经启动 小伙伴 a 已经进入就餐状态！ Thread-2 已经启动 小伙伴 b 已经进入就餐状态！ 主线程通知小伙伴开吃咯！ Thread-1 收到通知了. 小伙伴 a 开始吃咯！ Thread-2 收到通知了. 小伙伴 b 开始吃咯！

threading.Event()

ev.wait() ev.set() ev.clear()