Queue模組可以進行執行緒通訊。比如生產者產生貨物，貨物放入佇列，通過通訊，消費者取得貨物。Queue被稱為通用佇列模組
queue(size)產生一個佇列，佇列模式有3種，針對這三種佇列分別有三個建構函式:

1 FIFO佇列先進先出：class Queue.Queue(maxsize)
2 LIFO類似於堆,即先進後出：class Queue.LifoQueue(maxsize) 
3 優先順序佇列級別越低越先出來：class Queue.PriorityQueue(maxsize)

佇列長度可為無限或者有限。可通過Queue的建構函式的可選引數maxsize來設定佇列長度。如果maxsize小於1就表示佇列長度無限。呼叫佇列物件的put()方法在隊尾插入一個專案。put()有兩個引數，第一個item為必需的，為插入專案的值；第二個block為可選引數， 預設為1。如果隊列當前為空且block為1，put()方法就使呼叫執行緒暫停,直到空出一個數據單元。如果block為0，put方法將引發Full異常。呼叫佇列物件的get()方法從隊頭刪除並返回一個專案。可選引數為block，預設為1。如果佇列為空且block為1，get()就使呼叫執行緒暫停，直至有專案可用。如果block為0，佇列將引發Empty異常。join()保持阻塞狀態，直到處理了佇列中的所有專案為止。在將一個專案新增到該佇列時，未完成的任務的總數就會增加。當使用者執行緒呼叫task_done()以表示檢索了該專案、並完成了所有的工作時，那麼未完成的任務的總數就會減少。當未完成的任務的總數減少到零時，join() 就會結束阻塞狀態。

產生的佇列例項分別有以下操作方法：

例項:呼叫前面的 MyThread.py

# -*- coding: utf8 -*-

from random import
 
 randint  # randint隨機進行生產和消耗
from time import sleep
from Queue import Queue
from myThread import MyThread

#wwrite的貨物物件
def writeQ(queue):
    print '放置貨物', queue.put('xxx', 1)  # 把xxx物件放進佇列中，並等待佇列中有空間為止
    print "放置貨物後當前佇列大小", queue.qsize(),'\n'  # 返回佇列大小

#取得貨物
def readQ(queue):
    val = queue.get(1)  # 從佇列中取出一個物件（消耗）
    print val+'\n'
    print '取出貨物後當前佇列大小', queue.qsize(),'\n'  # 返回佇列大小

#writer 放置貨物
def writer(queue, loops):
    """一次往佇列中放進一個物件，等待一會，然後再做給定次數的相同的事"""
    for i in range(loops):
        writeQ(queue)  # 呼叫writeQ,放進一個物件
        sleep(randint(1, 3))  # 隨機睡眠1~3秒


def reader(queue, loops):
    """一次從佇列中取出一個物件，等待一會，然後做給定次數的相同的事"""
    for i in range(loops):
        readQ(queue)
        sleep(randint(2, 5))  # 睡眠時間比 write 中的長，以使 reader 在取資料的時候能夠拿到資料

funcs = [writer, reader]
nfuncs = range(len(funcs))


def main():
    nloops = randint(2, 5)
    q = Queue(32)  # 建立一個大小為32的物件，和 q 繫結

    threads = []
    for i in nfuncs:
        t = MyThread(funcs[i], (q, nloops), funcs[i].__name__)  # 例項化 writer, reader 這兩個物件
        threads.append(t)  # 放入空列表中

    for i in nfuncs:
        threads[i].start()  # 啟動執行緒

    for i in nfuncs:
        threads[i].join()  # join()會等到執行緒結束或超時，即允許主執行緒等待執行緒結束

    print 'all DONE'

if __name__ == '__main__':  # 獨立執行指令碼
    main()

輸出:

starting writer at: Wed Jul 20 12:18:51 2016
放置貨物 starting Nonereader
 放置貨物後當前佇列大小at:  1Wed Jul 20 12:18:51 2016 


xxx

取出貨物後當前佇列大小 0 

放置貨物 None
放置貨物後當前佇列大小 1 

xxx

取出貨物後當前佇列大小 0 

放置貨物 None
放置貨物後當前佇列大小 1 

xxx

取出貨物後當前佇列大小 0 

放置貨物 None
放置貨物後當前佇列大小 1 

放置貨物 None
放置貨物後當前佇列大小 2 

xxx

取出貨物後當前佇列大小 1 

writer finished at: Wed Jul 20 12:19:02 2016
xxx

取出貨物後當前佇列大小 0 

reader finished at: Wed Jul 20 12:19:08 2016
all DONE