Python提供了Queue模塊來(lái)專門實(shí)現(xiàn)消息隊(duì)列Queue對(duì)象

Queue對(duì)象實(shí)現(xiàn)一個(gè)fifo隊(duì)列(其他的還有l(wèi)ifo、priority隊(duì)列，這里不再介紹)。queue只有maxsize一個(gè)構(gòu)造參數(shù)，用來(lái)指定隊(duì)列容量，指定為0的時(shí)候代表容量無(wú)限。主要有以下成員函數(shù)：

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

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

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

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

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

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

以下兩個(gè)函數(shù)用來(lái)判斷消息對(duì)應(yīng)的任務(wù)是否完成。

Queue.task_done()：接受消息的線程通過(guò)調(diào)用這個(gè)函數(shù)來(lái)說(shuō)明消息對(duì)應(yīng)的任務(wù)已完成。

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

例子：

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

'''寫一個(gè)消費(fèi)者和生產(chǎn)者，為了練習(xí)多線程，用多線程的方式實(shí)現(xiàn)，并通過(guò)類的重寫的方法來(lái)實(shí)現(xiàn)'''

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

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#消費(fèi)者類

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()

輸出結(jié)果：

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!

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。