python条件变量之生产者与消费者操作实例分析

importthreading

importtime

classProducer(threading.Thread):

  def__init__(self):

    threading.Thread.__init__(self)

  defrun(self):

    globalcount

    whileTrue:

      con.acquire()

      ifcount <20:

        count+=1

        printself.name," Producer product 1,current is %d"%(count)

        con.notify()

      else:

        printself.name,"Producer say box is full"

        con.wait()

      con.release()

      time.sleep(1)

classConsumer(threading.Thread):

  def__init__(self):

    threading.Thread.__init__(self)

  defrun(self):

    globalcount

    whileTrue:

      con.acquire()

      ifcount>4:

        count-=4

        printself.name,"Consumer consume 4,current is %d"%(count)

        con.notify()

      else:

        con.wait()

        printself.name," Consumer say box is empty"

      con.release()

      time.sleep(1)

count=0

con=threading.Condition()

deftest():

  foriinrange(1):

    a=Consumer()

    a.start()

  foriinrange(1):

    b=Producer()

    b.start()

if__name__=='__main__':

  test()