快捷導(dǎo)航

python隊(duì)列基本操作和多線程隊(duì)列

更新時(shí)間：2022年02月10日 11:55:47 作者：侯小啾?

pythonQueue隊(duì)列模塊提供了同步線程安全的隊(duì)列類,包括FIFO（先入先出)隊(duì)列Queue，LIFO（后入先出）隊(duì)列LifoQueue,和優(yōu)先級(jí)隊(duì)列PriorityQueue,這些隊(duì)列都實(shí)現(xiàn)了鎖原語(yǔ),能夠在多線程中直接使用,可以使用隊(duì)列來(lái)實(shí)現(xiàn)線程間的同步，下面我們就來(lái)看看python隊(duì)列基本操作吧

一、隊(duì)列基本操作

from queue import Queue

q = Queue(5) ?# 創(chuàng)建一個(gè)容量為5的隊(duì)列。如果給一個(gè)小于0的數(shù)，則隊(duì)列為無(wú)限大小。（這是官方的解釋，實(shí)際不是無(wú)限大小，而是跟內(nèi)存有關(guān)）

# 存儲(chǔ)數(shù)據(jù)
q.put(123) ?# 數(shù)值?
q.put('hello world!') ?# 字符串
q.put(['hello', 'world']) ?# 列表
q.put(('hello', 'world')) ?# 元組
q.put({'hello': 'world'}) ?# 字典

# 如果再試圖存儲(chǔ)第六個(gè)，則會(huì)發(fā)生阻塞，因?yàn)槿萘恳言O(shè)定為5
# q.put({'hello': 'python'})

取出隊(duì)列中的值：

print(q.get())
print(q.get())
print(q.get())
print(q.get())
print(q.get())

如圖五個(gè)值被依次取出。Queue隊(duì)列遵循的是先進(jìn)先出。

q.put_nowait()

q.put_nowait()方法可以無(wú)阻礙地向隊(duì)列中添加內(nèi)容，如果隊(duì)列已滿則會(huì)立即報(bào)錯(cuò)，不會(huì)等待（即不會(huì)發(fā)生阻塞）。

q.get_nowait()

q.get_nowait()方法可以無(wú)阻礙地從隊(duì)列中取出內(nèi)容，如果隊(duì)列是空的則也會(huì)直接報(bào)錯(cuò)，不會(huì)等待。
具體使用不再示例。

查看隊(duì)列當(dāng)前大小

q.qsize()

print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())

如圖，每取出一個(gè)值，隊(duì)列大小就減一。同樣每存入一個(gè)值隊(duì)列大小就會(huì)加一。

q.full()

判斷隊(duì)列是否是滿的。

q.empty()

判斷隊(duì)列是否是空的。

print(q.full())
print(q.get())
print(q.get())
print(q.full())
print(q.empty())
print(q.get())
print(q.get())
print(q.get())
print(q.empty())

二、多線程隊(duì)列

from queue import Queue
import threading
import time


# 存儲(chǔ)值，每隔一秒存儲(chǔ)一個(gè)
def set_value(q):
? ? num = 0
? ? while True:
? ? ? ? q.put(num)
? ? ? ? num += 1
? ? ? ? time.sleep(1)

# 取值，不間斷地取
def get_value(q):
? ? while True:
? ? ? ? print(q.get())


if __name__ == '__main__':
? ? q = Queue(4)
? ? t1 = threading.Thread(target=set_value, args=(q, ))
? ? t2 = threading.Thread(target=get_value, args=(q, ))

? ? t1.start()
? ? t2.start()

程序開始運(yùn)行，一邊存儲(chǔ)，一邊取值：