扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
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() 
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
微信二维码
移动版官网