Event
事件对象管理一个内部标志,通过set()
方法将其设置为True
,并使用clear()
方法将其设置为False
。wait()
方法阻塞,直到标志为True
。该标志初始为False
。
方法:
is_set() 当且仅当内部标志为True
时返回True
。 set()
将内部标志设置为True
。所有等待它成为True
的线程都被唤醒。当标志保持在True
的状态时,线程调用wait()
是不会阻塞的。 clear()
将内部标志重置为False
。随后,调用wait()
的线程将阻塞,直到另一个线程调用set()
将内部标志重新设置为True
。 wait(timeout=None)
阻塞直到内部标志为真。如果内部标志在wait()
方法调用时为True
,则立即返回。否则,则阻塞,直到另一个线程调用set()
将标志设置为True
,或发生超时。 该方法总是返回True
,除非设置了timeout
并发生超时。 生产者与消费之--Event版
# -*- coding:utf-8 -*-import threadingimport timeimport queueevent = threading.Event()goods = queue.Queue(5)num = 0class Producer(threading.Thread): def run(self): global num while True: if goods.empty(): event.clear() for _ in range(5): goods.put('商品-' + str(num)) print('生产了商品-{0}.'.format(str(num))) num += 1 time.sleep(1) event.set()class Customer(threading.Thread): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self.money = 7 def run(self): while self.money: event.wait() self.money -= 1 print('{0} 买了一个{1}.'.format( threading.current_thread().name, goods.get())) time.sleep(1) print('{0}没钱了,回家.'.format(threading.current_thread().name))if __name__ == '__main__': p = Producer(daemon=True) c1 = Customer(name='Alice') c2 = Customer(name='Bob') c2.start() p.start() c1.start() c1.join() c2.join()
运行结果:
生产了商品-0.生产了商品-1.生产了商品-2.生产了商品-3.生产了商品-4.Alice 买了一个商品-0.Bob 买了一个商品-1.Alice 买了一个商品-2.Bob 买了一个商品-3.Alice 买了一个商品-4.生产了商品-5.生产了商品-6.生产了商品-7.生产了商品-8.生产了商品-9.Alice 买了一个商品-5.Bob 买了一个商品-6.Alice 买了一个商品-7.Bob 买了一个商品-8.生产了商品-10.Alice 买了一个商品-9.生产了商品-11.生产了商品-12.生产了商品-13.生产了商品-14.Alice 买了一个商品-10.Bob 买了一个商品-11.Alice没钱了,回家.Bob 买了一个商品-12.Bob 买了一个商品-13.Bob没钱了,回家.
这里会出现一种特殊情况,当消费者线程较多时会大量出现:
生产了商品-0.生产了商品-1.生产了商品-2.生产了商品-3.生产了商品-4.Bob 买了一个商品-0.Alice 买了一个商品-1.Bob 买了一个商品-2.Alice 买了一个商品-3.Bob 买了一个商品-4.生产了商品-5. # !!!!!Alice 买了一个商品-5. # !!!!!生产了商品-6.生产了商品-7.生产了商品-8.生产了商品-9.Bob 买了一个商品-6.Alice 买了一个商品-7.Alice 买了一个商品-8.Bob 买了一个商品-9.生产了商品-10.生产了商品-11.生产了商品-12.生产了商品-13.生产了商品-14.Alice 买了一个商品-10.Bob 买了一个商品-11.Bob 买了一个商品-12.Alice 买了一个商品-13.Bob没钱了,回家.Alice没钱了,回家.
这是因为生产者在轮询检查商品是否为空会有很小的延迟,在这个延迟中有消费者线程正好跑过了wait()
方法,而阻塞在了商品获取这里(商品使用了队列,队列是线程安全的,当队列为空时,get()方法会阻塞),所以当生产者开始执行的时候,这个消费者因为商品队列里有数据就被立即唤醒了。