Python提供了Queue模塊來專門實現消息隊列Queue對象

Queue對象實現一個fifo隊列(其他的還有lifo、priority隊列，這里不再介紹)。queue只有maxsize一個構造參數，用來指定隊列容量，指定為0的時候代表容量無限。主要有以下成員函數：

Queue.qsize()：返回消息隊列的當前空間。返回的值不一定可靠。

Queue.empty()：判斷消息隊列是否為空，返回True或False。同樣不可靠。

Queue.full()：類似上邊，判斷消息隊列是否滿

Queue.put(item, block=True, timeout=None)：往消息隊列中存放消息。block可以控制是否阻塞，timeout指定阻塞時候的等待時間。如果不阻塞或者超時，會引起一個full exception。

Queue.put_nowait(item)：相當于put(item, False).

Queue.get(block=True, timeout=None)：獲取一個消息，其他同put。

以下兩個函數用來判斷消息對應的任務是否完成。

Queue.task_done()：接受消息的線程通過調用這個函數來說明消息對應的任務已完成。

Queue.join()： 實際上意味著等到隊列為空，再執行別的操作

例子：

#!/usr/bin/env python#-*- coding:utf-8 -*-#@time: 2017/12/18 19:31#Author: caicai#@File: demon3.py

'''寫一個消費者和生產者，為了練習多線程，用多線程的方式實現，并通過類的重寫的方法來實現'''

from Queue importQueuefrom threading importThreadimporttime#生成類，輸出一堆數字

classProceduer(Thread):def __init__(self,queue):

super(Proceduer, self).__init__()

self.queue=queuedefrun(self):try:for i in xrange(1,10):print("put data is: {0} to queue".format(i))

self.queue.put(i)exceptException as e:print("put data error!")raisee#消費者類

classConsumer_odd(Thread):def __init__(self,queue):

super(Consumer_odd, self).__init__()

self.queue=queuedefrun(self):try:while notself.queue.empty():

number=self.queue.get()if number % 2 !=0:print("get {0} from queue ODD".format(number))else:

self.queue.put(number)

time.sleep(1)exceptException as e:raiseeclassConsumer_even(Thread):def __init__(self,queue):

super(Consumer_even, self).__init__()

self.queue=queuedefrun(self):try:while not self.queue.empty(): #queue.empty()

number =self.queue.get()if number % 2 ==0:print("get {0} from queue EVEN,thread name is: {1}".format(number, self.getName()))else:

self.queue.put(number)

time.sleep(1)exceptException as e:raiseedefmain():

queue=Queue()

p= Proceduer(queue=queue)

p.start()

p.join()

time.sleep(1)

c1= Consumer_odd(queue=queue)

c2= Consumer_even(queue=queue)

c1.start()

c2.start()

c1.join()

c2.join()print("All threads terminate!")if __name__ == '__main__':

main()

輸出結果：

put datais: 1to queue

put datais: 2to queue

put datais: 3to queue

put datais: 4to queue

put datais: 5to queue

put datais: 6to queue

put datais: 7to queue

put datais: 8to queue

put datais: 9to queue

get1 fromqueue ODD

get2 from queue EVEN,thread name is: Thread-3get5 fromqueue ODD

get6 from queue EVEN,thread name is: Thread-3get7 fromqueue ODD

get8 from queue EVEN,thread name is: Thread-3get9 fromqueue ODD

get4 from queue EVEN,thread name is: Thread-3get 3 fromqueue ODD

All threads terminate!

總結

以上是生活随笔為你收集整理的python消息队列模块_day43-python消息队列二-queue模块的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。