以下是代码：importthreadingimporttimeproducts=[]condition=threading.Condition()classConsumer(threading.Thread):defconsume(self):globalconditionglobalproductsconditon.acqu...

以下是代码：

import threading

import time

products=[]

condition = threading.Condition()

class Consumer(threading.Thread):

def consume(self):

global condition

global products

conditon.acquire()

if len(products)==0:

condition.wait()

print('消费提醒:没有产品去消费了')

products.pop()

print('消费者提醒：消费1个产品')

print('消费者提醒：还能消费的产品数为'+str(len(products)))

condition.notify()

condition.release()

def run(self):

for i in range(0,20):

time.sleep(4)

self.consume()

class Producer(threading.Thread):

def produce(self):

global condition

global products

condition.acquire()

if len(products)==10:

condition.wait()

print('生产者提醒：生成的产品数为'+str(len(products)))

print('生产者提醒：停止生产！')

products.append(1)

print('生产者提醒：产品总数为'+str(len(products)))

condition.notify()

condition.release()

def run(self):

for i in range(0,20):

time.sleep(1)

self.produce()

producer=Producer()

consumer=Consumer()

consumer.start()

producer.start()

producer.join()

consumer.join()

报错的提示：

Exception in thread Thread-2:

Traceback (most recent call last):

File "C:\Users\Administrator\AppData\Local\Programs\Python\Python38-32\lib\threading.py", line 932, in _bootstrap_inner

self.run()

File "C:/Users/Administrator/AppData/Local/Programs/Python/Python38-32/对对对.py", line 22, in run

self.consume()

File "C:/Users/Administrator/AppData/Local/Programs/Python/Python38-32/对对对.py", line 10, in consume

conditon.acquire()

NameError: name 'conditon' is not defined

展开