7810 - Python库 CP014【queue】标准库 - 列队模块详解

admin · 发表于 2021-9-28 22:44:32

马上注册，结交更多好友，享用更多功能，让你轻松玩转新大榭论坛！

您需要登录才可以下载或查看，没有账号？注册

x

Python Queue 模块详解

Python3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块，是提供队列操作的模块，虽然简单易用，但是不小心的话，还是会出现一些意外。

创建一个“队列”对象
import queue
q = queue.queue(maxsize = 10)
queue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。

将一个值放入队列中
q.put(10)
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数，第一个item为必需的，为插入项目的值；第二个block为可选参数，默认为
1。如果队列当前为空且block为1，put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0，put方法将引发Full异常。

将一个值从队列中取出
q.get()
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block，默认为True。如果队列为空且block为True，get()就使调用线程暂停，直至有项目可用。如果队列为空且block为False，队列将引发Empty异常。

Python queue模块有三种队列及构造函数:
1、Python queue模块的FIFO队列先进先出。 class queue.queue(maxsize)
2、LIFO类似于堆，即先进后出。 class queue.Lifoqueue(maxsize)
3、还有一种是优先级队列级别越低越先出来。 class queue.Priorityqueue(maxsize)

此包中的常用方法(q =queue.queue()):

q.qsize() 返回队列的大小，即输出队列中元素的个数
q.queue.queue(5) 建立一个长度为5的队列q
q.put(5) 将数字5入队
q.get() 队首元素出队
q.empty() 如果队列为空，返回True,反之False
7 A( @$ W a8 ^5 ]! pq.full() 如果队列满了，返回True,反之False
1 J0 |* |; I: |, v. z4 _q.full 与 maxsize 大小对应. N9 x: j8 B& d8 h
q.get([block[, timeout]]) 获取队列，timeout等待时间
' G( c+ ^: V# \6 o+ sq.get_nowait() 相当q.get(False)) O# \6 k0 {" W6 j7 P( r
非阻塞 q.put(item) 写入队列，timeout等待时间
1 @/ _6 U. R) v& N: pq.put_nowait(item) 相当q.put(item, False), ^* a5 Q) p' a+ n3 x" T9 m$ b/ `
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号9 k8 u8 D: N6 E% w5 ~) I( S3 s
q.join() 实际上意味着等到队列为空，再执行别的操作

代码实例 7810

import queue h: j0 U7 F- F* J1 P2 p
8 M' q6 E" W' j1 Y7 H# K
# 以下三个队列都可以设置最大长度maxsize,默认是无限大
5 }* u- L2 L& @" K
print("-------------queue.Queue----------------"): X6 m$ x, T* `/ S" x. z9 l: o
# 线程消息队列,FIFO(先进先出)
( X) m7 }2 V: L& y. j/ R1 a3 b
q = queue.Queue()2 z7 I! G) t& E( o+ {) e
q.put("one")
1 p/ q7 o9 B( {6 D* T3 N4 p$ y
q.put("two")2 G% E9 T4 s0 v! C
q.put("three")
1 ]" i# E3 Z; N# y/ m+ [5 c I5 p
print(q.get())" S$ c7 L( E, C# j/ }$ h0 q+ m% A
print(q.get())
1 A) P8 H i3 e, `) Y* s
print(q.get())1 g) T& U0 [. A% N
try:
- \1 C& n5 b7 ~" L6 I
# 队列中没有数据, 会阻塞。* l' f; z& R0 G
# 阻塞时间到了还没有数据抛出 queue.Empty 异常- Z: D8 U2 J+ s5 O) j7 A
print(q.get(timeout=3)): |% f# o, w9 ^0 X+ C% E# w2 E9 @
except queue.Empty as q_e:! P( M2 W7 o/ F" K5 @6 \
print('queue empty')
5 Y7 O8 j6 [" j
- l; w. @* R; X- Q1 X% N
print("-------------queue.LifoQueue----------------"); w+ L0 [, n4 u9 S$ x
# 线程消息队列,LIFO(后进先出); j4 f+ u/ u8 Y) M+ l+ N" Y/ |4 _
lq = queue.LifoQueue()
3 O4 N3 G( V% L( M. R
lq.put("one")! P& m9 L2 `! \# \8 ]% W% o) e; f
lq.put("two")
# g! D& T# p+ v2 O L1 A
lq.put("three")
' C3 F( ?4 V! G
print(lq.get())6 s, k& w' k/ J; y' ]* r6 L
print(lq.get())
( U W3 n9 K1 l. B3 @5 Y% f7 P
print(lq.get())1 a$ \- Y. f0 f5 N O) N
( l% I; v& T. N! X% ?
print("-------------queue.PriorityQueue----------------"). { v! V/ I* T, i
# 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高): O& y# {0 |- x8 y5 D/ f
pq = queue.PriorityQueue()! w, c2 ?, a' S4 s3 F
pq.put((1, "Jet"))3 d1 z: v3 |) c& Q$ s* i5 |
pq.put((3, "Jack"))
: g8 @# k* A1 h5 z! @
pq.put((2, "Judy"))
. x1 a3 i9 ~8 R% y1 _) }, e
print(pq.get())
; S# J5 H0 H$ ], m2 V
print(pq.get())
/ n4 C8 t) y. a% ~, y4 K% {9 \: c" Y
print(pq.get())

复制代码

		自动登录	找回密码
密码			注册

[模块] 7810 - Python库 CP014【queue】标准库 - 列队模块详解

马上注册，结交更多好友，享用更多功能，让你轻松玩转新大榭论坛！