Python标准库queue一个同步的队列类

• Z时代
• 2024-01-10
• 分类：综合

源代码: Lib/queue.py

queue 模块实现多生产者，多消费者队列。当信息必须安全的在多线程之间交换时，它在线程编程中是特别有用的。此模块中的 Queue 类实现了所有锁定需求的语义。它依赖于Python支持的线程可用性；请参阅 threading 模块。

模块实现了三种类型的队列，它们的区别仅仅是条目取回的顺序。在 FIFO 队列中，先添加的任务先取回。在 LIFO 队列中，最近被添加的条目先取回(操作类似一个堆栈)。优先级队列中，条目将保持排序( 使用 heapq 模块 ) 并且最小值的条目第一个返回。

在内部，这三个类型的队列使用锁来临时阻塞竞争线程；然而，它们并未被设计用于线程的重入性处理。

此外，模块实现了一个 "简单的" FIFO 队列类型， SimpleQueue ，这个特殊实现为小功能在交换中提供额外的保障。

queue 模块定义了下列类和异常：

class queue.Queue(maxsize=0)¶

Constructor for a FIFO queue. maxsize is

an integer that sets the upperbound

limit on the number of items that can be placed in the queue. Insertion will

block once this size has been reached, until queue items are consumed. If

maxsize is less than or equal to zero, the queue size is infinite.

class queue.LifoQueue(maxsize=0)¶

LIFO 队列构造函数。 maxsize 是个整数，用于设置可以放入队列中的项目数的上限。当达到这个大小的时候，插入操作将阻塞至队列中的项目被消费掉。如果 maxsize 小于等于零，队列尺寸为无限大。

class queue.PriorityQueue(maxsize=0)¶

优先级队列构造函数。 maxsize 是个整数，用于设置可以放入队列中的项目数的上限。当达到这个大小的时候，插入操作将阻塞至队列中的项目被消费掉。如果 maxsize 小于等于零，队列尺寸为无限大。

最小值先被取出( 最小值条目是由 sorted(list(entries))[0] 返回的条目)。条目的典型模式是一个以下形式的元组： (priority_number,data) 。

如果 data 元素没有可比性，数据将被包装在一个类中，忽略数据值，仅仅比较优先级数字 ：

python3 notranslate">

fromdataclassesimportdataclass,field
fromtypingimportAny
@dataclass(order=True)
classPrioritizedItem:
priority:int
item:Any=field(compare=False)

class queue.SimpleQueue¶

无界的 FIFO 队列构造函数。简单的队列，缺少任务跟踪等高级功能。

3.7 新版功能.

exception queue.Empty¶

对空的 Queue 对象，调用非阻塞的 get() (or get_nowait()) 时，引发的异常。

exception queue.Full¶

对满的 Queue 对象，调用非阻塞的 put() (or put_nowait()) 时，引发的异常。

defworker():
whileTrue:
item=q.get()
ifitemisNone:
break
do_work(item)
q.task_done()
q=queue.Queue()
threads=[]
foriinrange(num_worker_threads):
t=threading.Thread(target=worker)
t.start()
threads.append(t)
foriteminsource():
q.put(item)
# block until all tasks are done
q.join()
# stop workers
foriinrange(num_worker_threads):
q.put(None)
fortinthreads:
t.join()