一、線程隊(duì)列

queue隊(duì)列：使用方法同進(jìn)程的Queue一樣

如果必須在多個(gè)線程之間安全地交換信息時(shí)，隊(duì)列在線程編程中尤其有用。

重要：

q.put() :往隊(duì)列里面放值，當(dāng)參數(shù)block=Ture的時(shí)候，timeout參數(shù)將會(huì)有作用，當(dāng)隊(duì)列已經(jīng)滿了的時(shí)候，在往里面放值時(shí)，block為True程序?qū)?huì)等待timeout的時(shí)間，過了時(shí)間程序會(huì)報(bào)錯(cuò)，block如果為Flase時(shí)，程序不會(huì)等待直接報(bào)錯(cuò)

q.get() :從隊(duì)列里面取值，當(dāng)參數(shù)block=Ture的時(shí)候，timeout參數(shù)將會(huì)有作用，當(dāng)隊(duì)列已經(jīng)空了的時(shí)候，在從里面取值時(shí)，block為True程序?qū)?huì)等待timeout的時(shí)間，過了時(shí)間程序會(huì)報(bào)錯(cuò)，block如果為Flase時(shí)，程序不會(huì)等待直接報(bào)錯(cuò)

q.task_done() ：使用者使用此方法發(fā)出信號(hào)，表示q.get()返回的項(xiàng)目已經(jīng)被處理。如果調(diào)用此方法的次數(shù)大于從隊(duì)列中刪除的項(xiàng)目數(shù)量，將引發(fā)ValueError異常。

q.join() ：生產(chǎn)者將使用此方法進(jìn)行阻塞，直到隊(duì)列中所有項(xiàng)目均被處理。阻塞將持續(xù)到為隊(duì)列中的每個(gè)項(xiàng)目均調(diào)用q.task_done()方法為止。

二、線程隊(duì)列的取值方式

2.1 先進(jìn)先出

class queue.Queue(maxsize=0)

q = queue.Queue() ：不加參數(shù)代表隊(duì)列可以無限的放數(shù)據(jù)

q = queue.Queue() #不加參數(shù)代表隊(duì)列可以無限的放數(shù)據(jù)
q.put('Cecilia陳')
q.put('xichen')
print(q.get())
print(q.get())
'''
結(jié)果：
Cecilia陳
xichen
'''

2.2 后進(jìn)先出

class queue.LifoQueue(maxsize=0)

q = Lifo.Queue() ：不加參數(shù)代表隊(duì)列可以無限的放數(shù)據(jù)

q = queue.LifoQueue() #不加參數(shù)代表隊(duì)列可以無線的放數(shù)據(jù)
q.put('Cecilia陳')
q.put('xichen')

print(q.get())
print(q.get())
'''
結(jié)果：
xichen
Cecilia陳
'''

三、隊(duì)列存數(shù)據(jù)時(shí)可以設(shè)置優(yōu)先級(jí)

class queue.priorityQueue(maxsize=0)

q = queue.priorityQueue() ：不加參數(shù)代表隊(duì)列可以無限的放數(shù)據(jù)

3.1 優(yōu)先級(jí)隊(duì)列

# 3.優(yōu)先級(jí)隊(duì)列
q = queue.PriorityQueue() #不加參數(shù)代表隊(duì)列可以無線的放數(shù)據(jù)
#put進(jìn)入一個(gè)元組,元組的第一個(gè)元素是優(yōu)先級(jí)(通常是數(shù)字,也可以是非數(shù)字之間的比較),數(shù)字越小優(yōu)先級(jí)越高
q.put((2,'Cecilia陳'))
q.put((1,'xichen'))
q.put((5,'xuchen'))

print(q.get())
print(q.get())
print(q.get())
'''
# 結(jié)果(數(shù)字越小優(yōu)先級(jí)越高,優(yōu)先級(jí)高的優(yōu)先出隊(duì)):
結(jié)果：
(1, 'xichen')
(2, 'Cecilia陳')
(5, 'xuchen')
'''

3.2 方法說明

maxsize是一個(gè)整數(shù)，它設(shè)置可以放置在隊(duì)列中的項(xiàng)數(shù)的上限。一旦達(dá)到此大小，插入將阻塞，直到使用隊(duì)列項(xiàng)。如果maxsize小于或等于零，則隊(duì)列大小為無窮大。

p.put() :放值的時(shí)候，放的是一個(gè)元組（）

exception queue.Empty :異常隊(duì)列。空:當(dāng)對(duì)空的隊(duì)列對(duì)象調(diào)用非阻塞 get() 或 get_nowait() 時(shí)引發(fā)異常,也就是說隊(duì)列為空的時(shí)候，再取值就會(huì)報(bào)錯(cuò)

exception queue.Full :異常隊(duì)列。Full:當(dāng)對(duì)已滿的隊(duì)列對(duì)象調(diào)用非阻塞put() 或 put_nowait() 時(shí)引發(fā)異常。也就是說當(dāng)隊(duì)列已滿的時(shí)候，再往里面當(dāng)值的時(shí)候?qū)?huì)報(bào)錯(cuò)

Queue.qsize () :

empty() :如果為空，返回True

Queue.full() :如果已滿，返回True

put_nowait(item) :等同于put(item, False)。

get_nowait() :等同于get(False)。

提供了兩種方法來支持跟蹤已加入隊(duì)列的任務(wù)是否已被守護(hù)進(jìn)程使用者線程完全處理:

task_done() :表示以前加入隊(duì)列的任務(wù)已經(jīng)完成。由隊(duì)列使用者線程使用。對(duì)于用于獲取任務(wù)的每個(gè)get()，后續(xù)對(duì)task_done()的調(diào)用告訴隊(duì)列任務(wù)上的處理已經(jīng)完成。如果join(當(dāng)前處于阻塞狀態(tài)，那么在處理完所有項(xiàng)之后，它將繼續(xù)運(yùn)行(這意味著對(duì)于已經(jīng)放入隊(duì)列()的每個(gè)項(xiàng)，都收到了task_done()調(diào)用)。

如果調(diào)用次數(shù)超過放置在隊(duì)列中的項(xiàng)的次數(shù)，則引發(fā)ValueError。

Queue.join() :塊直到隊(duì)列被消費(fèi)完畢。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論