我已经编写了以下代码,看来一切都很好,但是我收到名称错误,说:名称“ Queue”未定义
from threading import *
import queue
import time
import random
def producer():
item=random.randint(1,100)
print('producer producing the item...',item)
q.put(item)
print('producer giving notificatio...')
time.sleep(3)
def consumer():
print('consumer waiting for the updation')
print('consumer consuming the item..',q.get())
time.sleep(4)
q=queue.Queue()
t1=Thread(target=consumer)
t2=Thread(target=producer)
t1.start()
t2.start()