#關(guān)于tase_done()的作用：只有消費者把隊列所有的數(shù)據(jù)處理完畢，queue.join()才會停止阻塞
import time
from queue import Queue
from threading import Thread
q = Queue()

def produce():
    for i in range(10):
        q.put(i)
        print('生產(chǎn)：',i)
    print('生產(chǎn)任務(wù)完畢！')
    q.join()
    print(produce.__name__,'函數(shù)結(jié)束！')

def consumer():
    for i in range(10):
        print('消費：', q.get())
        q.task_done()
        # if i == 4:
        #     print('休息1s...')
        #     time.sleep(1)#sleep作用：查看生產(chǎn)者是否阻塞
    print(consumer.__name__,'函數(shù)結(jié)束！')



pro = Thread(target=produce)
con = Thread(target=consumer)

pro.start()
con.start()

con.join()
print('消費者任務(wù)完成')
pro.join()
print('生產(chǎn)者任務(wù)完成')

#關(guān)于tase_done()的作用：只有消費者把隊列所有的數(shù)據(jù)處理完畢，queue.join()才會停止阻塞
import time
from queue import Queue
from threading import Thread
q = Queue()

def produce():
    for i in range(10):
        q.put(i)
    print('生產(chǎn)任務(wù)完畢！')
    # q.join()
    # if i == 4:
        #     print('休息1s...')
        #     time.sleep(1)#sleep作用：查看生產(chǎn)者是否阻塞
    print(produce.__name__,'函數(shù)結(jié)束！')

def consumer():
    for i in range(10):
        print('消費：', q.get())
        # q.task_done()
    print(consumer.__name__,'函數(shù)結(jié)束！')



pro = Thread(target=produce)
con = Thread(target=consumer)

pro.start()
con.start()

con.join()
print('消費者任務(wù)完成')
pro.join()
print('生產(chǎn)者任務(wù)完成')

#關(guān)于tase_done()的作用：只有消費者把隊列所有的數(shù)據(jù)處理完畢，queue.join()才會停止阻塞
import time
from queue import Queue
from threading import Thread
q = Queue()

def produce():
    for i in range(10):
        q.put(i)
    print('生產(chǎn)任務(wù)完畢！')
    q.join()
    print(produce.__name__,'函數(shù)結(jié)束！')

def consumer():
    for i in range(10):
        print('消費：', q.get())
        # q.task_done()
        # if i == 4:
        #     print('休息1s...')
        #     time.sleep(1)#sleep作用：查看生產(chǎn)者是否阻塞
    print(consumer.__name__,'函數(shù)結(jié)束！')



pro = Thread(target=produce)
con = Thread(target=consumer)

pro.start()
con.start()

con.join()
print('消費者任務(wù)完成')
pro.join()
print('生產(chǎn)者任務(wù)完成')