Queue 實現生產者消費者模型

Python中，隊列是線程間最經常使用的交換數據的形式。

Python Queue模塊有三種隊列及構造函數:
一、Python Queue模塊的FIFO隊列先進先出。 class Queue.Queue(maxsize)
二、LIFO相似於堆，即先進後出。 class Queue.LifoQueue(maxsize)
三、還有一種是優先級隊列級別越低越先出來。 class Queue.PriorityQueue(maxsize)

此包中的經常使用方法(q = Queue.Queue()):
q.qsize() 返回隊列的大小
q.empty() 若是隊列爲空，返回True,反之False
q.full() 若是隊列滿了，返回True,反之False
q.full 與 maxsize 大小對應
q.get([block[, timeout]]) 獲取隊列，timeout等待時間
q.get_nowait() 至關q.get(False)
非阻塞 q.put(item) 寫入隊列，timeout等待時間
q.put_nowait(item) 至關q.put(item, False)
q.task_done() 在完成一項工做以後，q.task_done() 函數向任務已經完成的隊列發送一個信號
q.join() 實際上意味着等到隊列爲空，再執行別的操做

# coding=utf-8

import Queue
import threading
import time


q = Queue.Queue(maxsize=10)  # 建立一個隊列對象，長度限制爲10，maxsize小於1就表明無限制


def producer(name):
    count = 1
    while True:
        q.put(count)  # 將值放入隊列中 默認block爲True，無數據時調用線程暫停，不然拋出異常
        print "%s 生產了包子 %d" % (name, count)
        count += 1
        time.sleep(0.5)


def consumer(name):
    while True:
        conut_con = q.get()  # 從隊列中取值 默認block爲True，無數據時調用線程暫停，不然拋出異常
        print "%s 吃掉了包子 %d" % (name, conut_con)
        time.sleep(2)


pro = threading.Thread(target=producer, args=("德源",))
con = threading.Thread(target=consumer, args=("xu",))
con2 = threading.Thread(target=consumer, args=("sx",))

pro.start()
con.start()
con2.start()  # 開啓線程