1：事件機制共享隊列：

創(chuàng)新互聯(lián)專注于芒康網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供芒康營銷型網(wǎng)站建設(shè)，芒康網(wǎng)站制作、芒康網(wǎng)頁設(shè)計、芒康網(wǎng)站官網(wǎng)定制、重慶小程序開發(fā)公司服務(wù)，打造芒康網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供芒康網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

利用消息機制在兩個隊列中，通過傳遞消息，實現(xiàn)可以控制的生產(chǎn)者消費者問題

要求：readthread讀時，writethread不能寫；writethread寫時，readthread不能讀。

基本方法 時間類（Event）

set：設(shè)置事件。將標志位設(shè)為True。

wait：等待事件。會將當前線程阻塞，直到標志位變?yōu)門rue。

clear：清除事件。將標志位設(shè)為False。

set() clear() 函數(shù)的交替執(zhí)行 也就是消息傳遞的本質(zhì)

模版：

基本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()

當前名稱：Python的條件鎖與事件共享詳解-創(chuàng)新互聯(lián)
本文鏈接：http://weahome.cn/article/dchsgh.html