queue 一個(gè)同步的隊(duì)列
queue模塊實(shí)現(xiàn)了多生產(chǎn)者赠法、多消費(fèi)者隊(duì)列。這特別適用于消息必須安全地在多線程間交換的線程編程。模塊中的 Queue類實(shí)現(xiàn)了所有所需的鎖定語(yǔ)義。
模塊實(shí)現(xiàn)了三種類型的隊(duì)列撑帖,它們的區(qū)別僅僅是條目取回的順序。
1澳眷、在 FIFO 隊(duì)列中胡嘿,先添加的任務(wù)先取回。
2钳踊、在 LIFO 隊(duì)列中衷敌,最近被添加的條目先取回(操作類似一個(gè)堆棧)。
3拓瞪、優(yōu)先級(jí)隊(duì)列中缴罗,條目將保持排序( 使用 heapq 模塊 ) 并且最小值的條目第一個(gè)返回。
在內(nèi)部祭埂,這三個(gè)類型的隊(duì)列使用鎖來(lái)臨時(shí)阻塞競(jìng)爭(zhēng)線程面氓;然而,它們并未被設(shè)計(jì)用于線程的重入性處理蛆橡。
queue 模塊定義了下列類:
class queue.Queue(maxsize = 0)
這是個(gè)FIFO隊(duì)列舌界,maxsize 是個(gè)整數(shù),是隊(duì)列中項(xiàng)數(shù)的最大上限泰演,一旦達(dá)到這個(gè)大小呻拌,插入新的項(xiàng)將會(huì)被阻塞,直到隊(duì)列被消耗睦焕。如果 maxsize 小于或等于0 柏锄,隊(duì)列的大小是無(wú)限的。
class queue.LifoQueue(maxsize = 0)
LIFO 后進(jìn)先出隊(duì)列复亏,maxsize 是個(gè)整數(shù)趾娃,是隊(duì)列中項(xiàng)數(shù)的最大上限,一旦達(dá)到這個(gè)大小缔御,插入新的項(xiàng)將會(huì)被阻塞抬闷,直到隊(duì)列被消耗。如果 maxsize 小于或等于0 ,隊(duì)列的大小是無(wú)限的笤成。
class queue.PriorityQueue(maxsize = 0)
參考1
參考2
參考3
參考4
優(yōu)先級(jí)隊(duì)列構(gòu)造函數(shù)评架,maxsize 是個(gè)整數(shù),是隊(duì)列中項(xiàng)數(shù)的最大上限炕泳,一旦達(dá)到這個(gè)大小纵诞,插入新的項(xiàng)將會(huì)被阻塞,直到隊(duì)列被消耗培遵。如果 maxsize 小于或等于0 浙芙,隊(duì)列的大小是無(wú)限的。
如果 data 元素沒(méi)有可比性籽腕,數(shù)據(jù)將被包裝在一個(gè)類中嗡呼,忽略數(shù)據(jù)值,僅僅比較優(yōu)先級(jí)數(shù)字 :
rom dataclasses import dataclass, field
from typing import Any
@dataclass(order=True)
class PrioritizedItem:
priority: int
item: Any=field(compare=False)