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

Python的互斥鎖與信號量

系統 1519 0

并發與鎖

  • a. 多個線程共享數據的時候,如果數據不進行保護,那么可能出現數 據不一致現象,使用鎖,信號量、條件鎖
    • b.
      • c. 互斥鎖
        1. 互斥鎖,是使用一把鎖把代碼保護起來,以犧牲性能換取代碼的安全性,那么Rlock后 必須要
        relase 解鎖 不然將會失去多線程程序的優勢
        2. 互斥鎖的基本使用規則:
                                1 
                                
                                  import
                                
                                
                                   threading
        
                                
                                2 
                                
                                  #
                                
                                
                                   聲明互斥鎖
                                
                                
        3 lock=
                                
                                  threading.Rlock();
        
                                
                                4 
                                
                                  def
                                
                                 handle(sid):
                                
                                  #
                                
                                
                                   功能實現代碼
                                
                                
        5 lock.acquire() 
                                
                                  #
                                
                                
                                  加鎖
                                
                                
        6 
                                
                                  #
                                
                                
                                   writer codeing
                                
                                
        7 lock.relase() 
                                
                                  #
                                
                                
                                  釋放鎖
                                
                              
        8
        信號量:
        1. 調用relarse()信號量會+1 調用 acquire() 信號量會-1
        a. 可以理解為對于臨界資源的使用,以及進入臨界區的判斷條件
        2. semphore() :當調用relarse()函數的時候 單純+1 不會檢查信號量的上限情況。 初
        始參數為0
        3. boudedsemphore():邊界信號量 當調用relarse() 會+1 , 并且會檢查信號量的上
        限情況。不允許超過上限
        a. 使用budedsemaphore時候不允許設置初始為0,將會拋出異常
        b. 至少設置為1 ,如consumer product 時候應該在外設置一個變
        量,啟動時候對變量做判斷,決定使不使用acquier
        4. 信號量的基本使用代碼:
                                1 
                                
                                  #
                                
                                
                                   聲明信號量:
                                
                                
        2 sema=threading.Semaphore(0); 
                                
                                  #
                                
                                
                                  無上限檢查
                                
                                
        3 sema=threading.BuderedSeamphore(1) 
                                
                                  #
                                
                                
                                  有上限檢查設置
                                
                                
        4 5
                                
                                  
        apple
                                
                                =1
        6 
                                
                                  def
                                
                                
                                   consumner():
        
                                
                                7 seam.acquire(); 
                                
                                  #
                                
                                
                                   ‐1
                                
                                
        8 9
        
                                
                                  if
                                
                                 apple==1
                                
                                  :
        
                                
                                10 
                                
                                  pass
                                
                                
        11 
                                
                                  else
                                
                                : sema2.release();
                                
                                  #
                                
                                
                                  + 1
                                
                                
        12 
                                
                                  def
                                
                                
                                   product():
        
                                
                                13 seam.relarse(); 
                                
                                  #
                                
                                
                                   +1
                                
                                
        14 
                                
                                  if
                                
                                 apple==1
                                
                                  :
        
                                
                                15 
                                
                                  pass
                                
                                
        16 
                                
                                  else
                                
                                
                                  :
        
                                
                                17 
                                
                                  print
                                
                                (
                                
                                  "
                                
                                
                                  消費:
                                
                                
                                  "
                                
                                
                                  ,apple);
        
                                
                                18 
                                



      • 全部的代碼:
      •                         
                                  #
                                
                                
                                   -*- coding: utf-8 -*-
                                
                                
                                  """
                                
                                
                                  
        Created on Mon Sep  9 21:49:30 2019
        
        @author: DGW-PC
        
                                
                                
                                  """
                                
                                
                                  #
                                
                                
                                   信號量解決生產者消費者問題
                                
                                
                                  import
                                
                                
                                   random;
        
                                
                                
                                  import
                                
                                
                                   threading;
        
                                
                                
                                  import
                                
                                
                                   time;
        
        
                                
                                
                                  #
                                
                                
                                   聲明信號量
                                
                                
        sema=threading.Semaphore(0);
                                
                                  #
                                
                                
                                   必須寫參數 0 表示可以使用數
                                
                                
        sema2=threading.BoundedSemaphore(1
                                
                                  );
        
        apple
                                
                                =1
                                
                                  ;
        
        
                                
                                
                                  def
                                
                                 product():
                                
                                  #
                                
                                
                                  生產者
                                
                                
                                  global
                                
                                
                                   apple;
            apple
                                
                                =random.randint(1,100
                                
                                  );
            time.sleep(
                                
                                3
                                
                                  );
            
                                
                                
                                  print
                                
                                (
                                
                                  "
                                
                                
                                  生成蘋果:
                                
                                
                                  "
                                
                                
                                  ,apple);
            
                                
                                
                                  #
                                
                                
                                  sema2.release(); # +1
                                
                                
                                  if
                                
                                 apple==1
                                
                                  :
                 
                                
                                
                                  pass
                                
                                
                                  else
                                
                                : sema2.release();
                                
                                  #
                                
                                
                                  + 1 
                                
                                
                                  def
                                
                                
                                   consumer():
            
                                
                                
                                  print
                                
                                (
                                
                                  "
                                
                                
                                  等待
                                
                                
                                  "
                                
                                
                                  );
            sema2.acquire();
                                
                                
                                  #
                                
                                
                                   -1
                                
                                
                                  if
                                
                                 apple==1
                                
                                  :
                
                                
                                
                                  pass
                                
                                
                                  else
                                
                                
                                  :        
                
                                
                                
                                  print
                                
                                (
                                
                                  "
                                
                                
                                  消費:
                                
                                
                                  "
                                
                                
                                  ,apple);
            
        
        threads
                                
                                =
                                
                                  [];
        
        
                                
                                
                                  for
                                
                                 i 
                                
                                  in
                                
                                 range(1,3
                                
                                  ):
            t1
                                
                                =threading.Thread(target=
                                
                                  consumer);
            t2
                                
                                =threading.Thread(target=
                                
                                  product);
            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條評論
主站蜘蛛池模板: 色综合色综合色综合色综合网 | 特级一级毛片视频免费观看 | 天天草天天干 | 伊人天天操 | 伊人第一路线 | 亚洲欧美日韩在线观看你懂的 | 真实子伦视频不卡 | 亚洲人成绝费网站色ww | 国产一区二区亚洲精品天堂 | 日本深夜影院 | 国产精品嫩草研究所永久网址 | 真人一级毛片免费观看视频 | 在线免费福利 | 欧美亚洲另类久久综合 | 亚洲夜夜骑 | 九九99久麻豆精品视传媒 | 国产福利在线观看永久视频 | 国产自产视频在线观看香蕉 | 国产精品免费看香蕉 | 中国一级全黄的免费观看 | 模特啪啪| 亚洲毛片网 | 番茄视频成人在线观看 | 国产精品久久久久影院色老大 | 欧美一级a俄罗斯毛片 | 国产精品欧美一区二区三区不卡 | 成人国产精品一级毛片视频 | 性大特级毛片视频 | 亚洲精品69 | 五月婷婷国产 | 国产高清天干天天视频 | 亚洲第一区香蕉_国产a | 国产成人高清在线观看播放 | 日韩女人做爰大片 | 在线看一区 | 九九热精品视频在线播放 | 欧美午夜精品久久久久免费视 | 中文字幕高清免费不卡视频 | 欧美一区二区三区成人看不卡 | 国产精品视频福利视频网 | 四虎网站入口 |