快捷導航

python隊列基本操作和多線程隊列

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

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

一、隊列基本操作

from queue import Queue

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

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

# 如果再試圖存儲第六個，則會發(fā)生阻塞，因為容量已設(shè)定為5
# q.put({'hello': 'python'})

取出隊列中的值：

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

如圖五個值被依次取出。Queue隊列遵循的是先進先出。

q.put_nowait()

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

q.get_nowait()

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

查看隊列當前大小

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

如圖，每取出一個值，隊列大小就減一。同樣每存入一個值隊列大小就會加一。

q.full()

判斷隊列是否是滿的。

q.empty()

判斷隊列是否是空的。

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

二、多線程隊列

from queue import Queue
import threading
import time


# 存儲值，每隔一秒存儲一個
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()

程序開始運行，一邊存儲，一邊取值：