快捷導(dǎo)航

python條件變量之生產(chǎn)者與消費(fèi)者操作實(shí)例分析

更新時(shí)間：2017年03月22日 11:39:04 作者：聰明的狐貍

這篇文章主要介紹了python條件變量之生產(chǎn)者與消費(fèi)者操作,結(jié)合具體實(shí)例形式分析了Python條件變量的概念、原理、及線程操作的相關(guān)技巧,需要的朋友可以參考下

本文實(shí)例講述了python條件變量之生產(chǎn)者與消費(fèi)者操作。分享給大家供大家參考，具體如下：

互斥鎖是最簡(jiǎn)單的線程同步機(jī)制，面對(duì)復(fù)雜線程同步問(wèn)題，Python還提供了Condition對(duì)象。Condition被稱(chēng)為條件變量，除了提供與Lock類(lèi)似的acquire和release方法外，還提供了wait和notify方法。線程首先acquire一個(gè)條件變量，然后判斷一些條件。如果條件不滿(mǎn)足則wait；如果條件滿(mǎn)足，進(jìn)行一些處理改變條件后，通過(guò)notify方法通知其他線程，其他處于wait狀態(tài)的線程接到通知后會(huì)重新判斷條件。不斷的重復(fù)這一過(guò)程，從而解決復(fù)雜的同步問(wèn)題。

可以認(rèn)為Condition對(duì)象維護(hù)了一個(gè)鎖（Lock/RLock)和一個(gè)waiting池。線程通過(guò)acquire獲得Condition對(duì)象，當(dāng)調(diào)用wait方法時(shí)，線程會(huì)釋放Condition內(nèi)部的鎖并進(jìn)入blocked狀態(tài)，(但實(shí)際上不會(huì)block當(dāng)前線程）同時(shí)在waiting池中記錄這個(gè)線程。當(dāng)調(diào)用notify方法時(shí)，Condition對(duì)象會(huì)從waiting池中挑選一個(gè)線程，通知其調(diào)用acquire方法嘗試取到鎖。

Condition對(duì)象的構(gòu)造函數(shù)可以接受一個(gè)Lock/RLock對(duì)象作為參數(shù)，如果沒(méi)有指定，則Condition對(duì)象會(huì)在內(nèi)部自行創(chuàng)建一個(gè)RLock。

線程同步經(jīng)典問(wèn)題----生產(chǎn)者與消費(fèi)者問(wèn)題可以使用條件變量輕松解決。

import threading
import time
class Producer(threading.Thread):
  def __init__(self):
    threading.Thread.__init__(self)
  def run(self):
    global count
    while True:
      con.acquire()
      if count <20:
        count += 1
        print self.name," Producer product 1,current is %d" %(count)
        con.notify()
      else:
        print self.name,"Producer say box is full"
        con.wait()
      con.release()
      time.sleep(1)
class Consumer(threading.Thread):
  def __init__(self):
    threading.Thread.__init__(self)
  def run(self):
    global count
    while True:
      con.acquire()
      if count>4:
        count -=4
        print self.name,"Consumer consume 4,current is %d" %(count)
        con.notify()
      else:
        con.wait()
        print self.name," Consumer say box is empty"
      con.release()
      time.sleep(1)
count = 0
con = threading.Condition()
def test():
  for i in range(1):
    a = Consumer()
    a.start()
  for i in range(1):
    b =Producer()
    b.start()
if __name__=='__main__':
  test()

上面的代碼假定消費(fèi)者消費(fèi)的比較快，輸出結(jié)果為：