隊列 生産者消費者模型

# 隊列為了協調線程

# task_done() 給正在等待的 join()  發信号
# 沒有task_done() 的信号 join() 會一直等待

import queue,threading,time

que = queue.Queue()

def Soo(name):
    count = 0
    while count < 5:
        print('%s start baozi'%name + "##########")
        que.put(count)
        que.task_done()
        time.sleep(3)
        count += 1


def Coo(name):
    count = 0
    while count<5:
        # time.sleep(3)
        que.join()
        data = que.get()
        print('%s eat baozi %s 号'%(name,data) + '---------')
        count += 1

t1 = threading.Thread(target=Soo,args=('A',))
t2 = threading.Thread(target=Coo,args=("B",))
t1.start()
t2.start()
      

A start baozi##########
B eat baozi 0 号---------
A start baozi##########
B eat baozi 1 号---------
A start baozi##########
B eat baozi 2 号---------
A start baozi##########
B eat baozi 3 号---------
A start baozi##########
B eat baozi 4 号---------
      

+——————————————————————————      

print(que.full())   # 判斷隊列是否滿
print(que.empty())  # 判斷隊列是否為空   為空傳回TRUE 反之傳回Fuse
print(que.qsize())   # 判斷隊列裡面有幾個資料