亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Python的條件鎖與事件共享

系統 1829 0

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

?

參考代碼:

            
              #
            
            
               -*- coding: utf-8 -*-
            
            
              """
            
            
              
Created on Tue Sep 10 20:10:10 2019

@author: DGW-PC

            
            
              """
            
            
              #
            
            
               事件消息機制
            
            
              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):
        data
            
            =[random.randint(1,100) 
            
              for
            
             _ 
            
              in
            
             range(0,10
            
              )];
        self.queue.put(data);
        
            
            
              print
            
            (
            
              "
            
            
              WriteThread寫隊列:
            
            
              "
            
            
              ,data);
        self.rt.set(); 
            
            
              #
            
            
               發送讀事件
            
            
              print
            
            (
            
              "
            
            
              WriteThread通知讀
            
            
              "
            
            
              );
        
            
            
              print
            
            (
            
              "
            
            
              WriteThread等待寫
            
            
              "
            
            
              );
        self.wt.wait();
        
            
            
              print
            
            (
            
              "
            
            
              WriteThread收到寫事件
            
            
              "
            
            
              );
        self.wt.clear();
        
            
            6

            
              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();
            
            
              #
            
            
               等待寫事件 帶來
            
            
              print
            
            (
            
              "
            
            
              ReadThread 收到讀事件
            
            
              "
            
            
              );
            
            
            
              print
            
            (
            
              "
            
            
              ReadThread 開始讀{0}
            
            
              "
            
            
              .format(self.queue.get()));
            
            
            
              print
            
            (
            
              "
            
            
              ReadThread 發送寫事件
            
            
              "
            
            
              );
            self.wt.set();
            self.rt.clear();
q
            
            =
            
              queue.Queue();
rt
            
            =
            
              Event();
wt
            
            =
            
              Event();
writethread
            
            =WriteThread(q,wt,rt); 
            
              #
            
            
               實例化對象的
            
            
readthread=ReadThread(q,wt,rt);   
            
              #
            
            
               實例化對象的
            
            
              
writethread.start();
readthread.start();
            
          

?



2:條件鎖同步生產者消費者

作用: 在保護互斥資源的基礎上,增加了條件判斷的機制
即為使用wait() 函數 判斷不滿足當前條件的基礎上,讓當前線程的阻塞。
其他線程如果生成了滿足了條件的資源 使用notify() notifyALl() 函數將刮起線程喚醒。
使用了 threading 的Condition 類
acquire() : 鎖住當前資源
relarse() :釋放當前鎖住的資源
wait:掛起當前線程, 等待喚起 。
? notify:喚起被 wait 函數掛起的線程 。
? notif計All:喚起所有線程,防止線程永遠處于沉默狀態 。

?
模版:

            
              基本code

            
            
              from
            
            
               threading import Thread

            
            
              from
            
            
               threading import Condition
import random
import time

            
            
              lock
            
            =
            
              Condition(); # 聲明條件鎖
flag
            
            =
            
              0
            
            
              ;
def cnsumer():
    
            
            
              lock
            
            
              .acquire();
    
            
            
              while
            
             flag==
            
              0
            
            
              :
        
            
            
              lock
            
            
              .wait();
   
   業務代碼
            
            ---        

            
              lock
            
            
              .relarse();
      
def product():
    
            
            
              lock
            
            
              .acquire();
    
    釋放鎖之前對控制變量進行操作,數據的操作控制 可以作為全局變量來鎖定
    
            
            
              lock
            
            
              .notifyALl();
    
            
            
              lock
            
            .relarse();
            



?

?

?參考代碼code:

            
              #
            
            
               -*- coding: utf-8 -*-
            
            
              """
            
            
              
Created on Wed Sep 11 21:40:41 2019

@author: DGW-PC

            
            
              """
            
            
              #
            
            
               條件鎖生產者消費者
            
            
              from
            
             threading 
            
              import
            
            
               Thread

            
            
              from
            
             threading 
            
              import
            
            
               Condition

            
            
              import
            
            
               random

            
            
              import
            
            
               time

flag
            
            =0; 
            
              #
            
            
               聲明控制標志
            
            
goods=0; 
            
              #
            
            
               事物表示
            
            
lock=
            
              Condition();

            
            
              def
            
            
               consumer(x):
    
            
            
              global
            
            
               flag;
    
            
            
              global
            
            
               goods;
    lock.acquire(); 
            
            
              #
            
            
               取得鎖
            
            
              while
            
             flag==0: 
            
              #
            
            
               便于多次進行消費
            
            
              print
            
            (
            
              "
            
            
              consumer %d進入等待
            
            
              "
            
             %
            
               x);
         lock.wait();
    
            
            
              print
            
            (
            
              "
            
            
              consumer {0}:消費了{1}
            
            
              "
            
            .format(x,goods));
            
              #
            
            
               format 次序從0開始
            
            
    flag-=1
            
              ;
    lock.release(); 
            
            
              #
            
            
              釋放鎖
            
            
              def
            
            
               product(x):
    
            
            
              global
            
            
               flag;
    
            
            
              global
            
            
               goods;
    time.sleep(
            
            3
            
              );
    lock.acquire();
    goods
            
            =random.randint(1,1000
            
              );
    
            
            
              print
            
            (
            
              "
            
            
              product {0} 產生了{1}
            
            
              "
            
            
              .format(x,goods));
    flag
            
            +=1
            
              ;
    lock.notifyAll();
    lock.release();

threads
            
            =
            
              [];


            
            
              for
            
             i 
            
              in
            
             range(0,2
            
              ):
    t1
            
            =Thread(target=consumer,args=
            
              (i,));
    t2
            
            =Thread(target=product,args=
            
              (i,));
    t1.start();
    t2.start();
    threads.append(t1);
    threads.append(t2);


            
            
              for
            
             x 
            
              in
            
            
               threads:
    x.join();
    
            
          

?


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 国产网红主播 | 日本乱中文字幕系列在线观看 | 欧美日韩亚洲成人 | 夜夜操狠狠操 | 欧美成人猛男性色生活 | 日韩精品中文字幕一区二区三区 | 亚洲 中文 欧美 日韩 在线人 | 不卡一区在线观看 | 在线免费h | 五月天在线免费视频 | 国产精品午夜高清在线观看 | 国产精品露脸张开双腿 | 男人天堂免费 | 福利色姬网站视频入口 | 久久网页| 天天做天天爽爽快快 | 狠狠色综合色综合网络 | 国产精品免费综合一区视频 | 久久99精品久久久久久秒播放器 | 成年午夜性视频免费播放 | 99精品视频观看 | 成人毛片大全 | 综合亚洲欧美日韩一区二区 | 精品日产一区二区 | 亚洲免费在线观看 | 四只虎免费永久观看地址 | aaaaaa国产毛片孕妇版 | 2018天天操天天干 | 欧美成人午夜精品一区二区 | 一区二区三区在线 | 日本 | 成人黄色一级毛片 | 秋霞在线观看成人高清视频51 | 求毛片 | a级在线观看视频 | 爱爱精品视频 | 亚洲曰本大成网站mmm | 欧美在线成人免费国产 | 中文字幕一区二区区免 | 欧美精| 亚洲精品日本高清中文字幕 | 国产成人午夜性视频影院 |