Python之queue模块

import queue
import threading


message = queue.Queue(10)


def produce(i):#生产者
    #while True:
    msg = message.put(i)#元素放进队列
    print(‘put:‘,i)
def consumer(i):#消费者
    #while True:
    msg = message.get()#等待拿走元素，如果一直没有，线程不会结束，而且队列内一个元素被拿走了就在队列里面去除了
    print(msg)

for i in range(10):
    t = threading.Thread(target=produce,args=(i,))
    t.start()
print(message.qsize())

for i in range(15):#每个人去队列里面取值
    t = threading.Thread(target=consumer,args=(i,))
    t.start()

print(message.qsize())