十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
1:事件机制共享队列:
利用消息机制在两个队列中,通过传递消息,实现可以控制的生产者消费者问题
要求:readthread读时,writethread不能写;writethread写时,readthread不能读。
基本方法 时间类(Event)
set:设置事件。将标志位设为True。
wait:等待事件。会将当前线程阻塞,直到标志位变为True。
clear:清除事件。将标志位设为False。
set() clear() 函数的交替执行 也就是消息传递的本质
模版:
基本code # 事件消息机制 import queue import threading import random from threading import Event from threading import Thread class WriteThread(Thread): def __init__(self,q,wt,rt): super().__init__(); self.queue=q; self.rt=rt; self.wt=wt; def run(self): self.rt.set() self.wt.wait(); self.wt.clear(); class ReadThread(Thread): def __init__(self,q,wt,rt): super().__init__(); self.queue=q; self.rt=rt; self.wt=wt; def run(self): while True: self.rt.wait(); self.wt.wait(); self.wt.clear()