# -*- coding: utf-8 -*-
"""
Created on Wed Nov 28 17:15:29 2018

@author: 18665
"""

import threading
import time

class Producer(threading.Thread):
  # 生產(chǎn)者函數(shù)
  def run(self):
    global count
    while True:
      if con.acquire():
        # 當(dāng)count 小于等于1000 的時(shí)候進(jìn)行生產(chǎn)
        if count > 1000:
          con.wait()
        else:
          count = count+100
          msg = self.name+' produce 100, count=' + str(count)
          print(msg)
          # 完成生成后喚醒waiting狀態(tài)的線程，
          # 從waiting池中挑選一個(gè)線程，通知其調(diào)用acquire方法嘗試取到鎖
          con.notify()
        con.release()
        time.sleep(1)

class Consumer(threading.Thread):
  # 消費(fèi)者函數(shù)
  def run(self):
    global count
    while True:
      # 當(dāng)count 大于等于100的時(shí)候進(jìn)行消費(fèi)
      if con.acquire():
        if count < 100:
          con.wait()
        
        else:
          count = count-5
          msg = self.name+' consume 5, count='+str(count)
          print(msg)
          con.notify()
          # 完成生成后喚醒waiting狀態(tài)的線程，
          # 從waiting池中挑選一個(gè)線程，通知其調(diào)用acquire方法嘗試取到鎖
        con.release()
        time.sleep(1)

count = 500
con = threading.Condition()

def test():
  for i in range(2):
    p = Producer()
    p.start()
  for i in range(5):
    c = Consumer()
    c.start()
if __name__ == '__main__':
  test()