queue.
Queue
(maxsize=0) #先入先出,maxsize限制数量
queue.
LifoQueue
(maxsize=0) #last in fisrt out
queue.
PriorityQueue
(maxsize=0) #存储数据时可设置优先级的队列
Queue.
put
(item, block=True, timeout=None)#放入队列
Queue.
get
(block=True, timeout=None)#队列取出,block为false去到0不会卡住
Queue.
qsize
()#判断队列大小Queue.
full
() # return True if fullQueue.empty()#如果队列空则返回真
import threading,time
import queue
q = queue.Queue(maxsize=10)
def Producer(name):
count = 1
while True:
q.put("骨头%s" % count)
print("生产了骨头",count)
count +=1
time.sleep(0.1)
def Consumer(name):
while True:
print("[%s] 取到[%s] 并且吃了它..." %(name, q.get()))
time.sleep(1)
p = threading.Thread(target=Producer,args=("Techer",))
c = threading.Thread(target=Consumer,args=("dog1",))
c1 = threading.Thread(target=Consumer,args=("dog2",))
p.start()
c.start()
c1.start()