import threading
import queue
import time

#定義一個生產(chǎn)者
def producer():
    count = 0
    #判斷隊列中任務(wù)的數(shù)量
    while q.qsize()<5:
        print('第%s頓飯......',count)
        q.put(count)
        count+=1
        time.sleep(1)

import threading
import queue
import time

#定義一個消費者
def consumer(name):
    while True:
        print("%s 吃了第%s飯" % (name,q.get()))

import threading
import queue
import time

#定義一個隊列
q = queue.Queue(maxsize=4)

t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer,args=('jibu',))
t1.start()
t2.start()

第%s頓飯...... 0
jibu 吃了第0飯
第%s頓飯...... 1
jibu 吃了第1飯
第%s頓飯...... 2
jibu 吃了第2飯
第%s頓飯...... 3
jibu 吃了第3飯
第%s頓飯...... 4
jibu 吃了第4飯
第%s頓飯...... 5
jibu 吃了第5飯
第%s頓飯...... 6
jibu 吃了第6飯
第%s頓飯...... 7
jibu 吃了第7飯
第%s頓飯...... 8

# 另外，如果供大于求或者求大于供，可以在相對小的一方在增加線程的數(shù)量

import threading
import queue
import time

#定義一個生產(chǎn)者
def producer():
    count = 0
    #判斷隊列中任務(wù)的數(shù)量
    for i in range(5):
        print('第%s頓飯......',count)
        q.put(count)
        count+=1
        time.sleep(1)
    q.join()

#定義一個消費者
def consumer(name):
    while True:
        print("%s 吃了第%s飯" % (name,q.get()))
        q.task_done()

        print('消費者執(zhí)行完了所有任務(wù)')


#定義一個隊列
q = queue.Queue(maxsize=4)

t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer,args=('jibu',))
t1.start()
t2.start()

結(jié)果
第0頓飯......
jibu 吃了第0飯
消費者執(zhí)行完了所有任務(wù)
第1頓飯......
jibu 吃了第1飯
消費者執(zhí)行完了所有任務(wù)
第2頓飯......
jibu 吃了第2飯
消費者執(zhí)行完了所有任務(wù)
第3頓飯......
jibu 吃了第3飯
消費者執(zhí)行完了所有任務(wù)
第4頓飯......
jibu 吃了第4飯
消費者執(zhí)行完了所有任務(wù)