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

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條評論
主站蜘蛛池模板: 全部免费的毛片在线看青青 | 在线精品免费视频 | 国产黄色影院 | 色域综合 | 日本一区高清视频 | 天天色天天干天天 | 国产亚洲美女精品久久久2020 | 伊人久久视频 | 奇米影视久久 | 亚洲图片欧美日韩 | 七七影院九色桃花78 | 91视频你懂的| 玖玖在线精品 | 日韩精品一区二区三区中文字幕 | 高清在线一区 | a成人毛片免费观看 | 正在播放一区 | 成人在线亚洲 | 手机看片99| 国产99在线视频 | 一本清高清dvd日本播放器 | 国产欧美成人免费观看视频 | 熊出没之重启未来免费观看 | 91精品久久久久久久久久 | 中文字幕日韩精品麻豆系列 | 伊人激情久久综合中文字幕 | 国产日韩不卡免费精品视频 | 久久九九热re6这里有精品 | 日本一级淫片a的一级欧美 日本一级淫片a免费播放 | 久草视频国产 | 国产一级在线观看www色 | 国产精品久久天天影视 | 免费国产福利 | 久久伊人免费视频 | 夜夜嘿视频免费看 | 亚洲小视频在线 | 91九色视频无限观看免费 | 一区二区亚洲视频 | 久久精品视频大全 | 欧美亚洲激情 | 一级毛片免费的 |