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' b0 n1 I& E/ {2 b& K+ A
q.full() 如果队列满了，返回True,反之False# f- T/ W9 p. g9 H# C& g
q.full 与 maxsize 大小对应
6 b) w; w: d. O0 D( X) _q.get([block[, timeout]]) 获取队列，timeout等待时间' S! f% B$ y  W" _' n$ y
q.get_nowait() 相当q.get(False)" L8 Z' _: ~0 h9 z& q* N$ D1 i* V
非阻塞 q.put(item) 写入队列，timeout等待时间
; |7 o0 k. f) B; U3 K9 `! Qq.put_nowait(item) 相当q.put(item, False)
  A, R0 c4 E. u( H: aq.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
5 L- Q  z0 f1 ?1 N  mq.join() 实际上意味着等到队列为空，再执行别的操作

代码实例 7810

import queue
6 A) _( Y# G" c$ ~- I+ ~- p8 R) N8 n6 a
9 p# E! a Q- o8 M
# 以下三个队列都可以设置最大长度maxsize,默认是无限大
1 Y/ Y. W; j" r; Z( |% v
print("-------------queue.Queue----------------")# [$ c7 _ h1 C
# 线程消息队列,FIFO(先进先出)% j, K# |' K) y) R- v! x
q = queue.Queue()! K. a8 A, X! L4 n6 N
q.put("one") F5 @4 E' V, c9 v9 c0 c* r3 r- U o
q.put("two")6 }6 d. \; B5 c5 F h: ?) Z
q.put("three")
* \+ g2 T+ B: C( A1 B7 r% k
print(q.get())* r2 B2 N% A, h& ?4 S7 J3 a3 W) X
print(q.get())' {9 [2 z0 b% Y1 k) J
print(q.get())2 K& E$ t2 |& l& y
try:- G+ @6 [& X& a* _4 _
# 队列中没有数据, 会阻塞。
4 B* a( E" n8 S9 x5 ~5 I
# 阻塞时间到了还没有数据抛出 queue.Empty 异常3 O' ^/ F: c+ o3 {; _
print(q.get(timeout=3))
: v0 b+ W! W0 F, w1 d: h- }
except queue.Empty as q_e:. A& M1 a5 K" ~. f. X l5 v
print('queue empty')
' G/ a7 ?: `% }
2 f$ l% I! B( n0 U+ m6 J
print("-------------queue.LifoQueue----------------")
2 n5 J1 n! l" G; I/ T' c
# 线程消息队列,LIFO(后进先出)
) R4 x z* d) w7 x" z; ~
lq = queue.LifoQueue()
" f9 W! }6 T& m+ G* W7 S
lq.put("one"); u/ k$ i9 M, t6 u; M2 Y- N
lq.put("two")
- M# Z1 u2 W2 M" \2 ^+ l
lq.put("three")
) u, L1 j( M" S/ c0 S
print(lq.get())% B+ Y2 o8 \. c2 D4 ~$ D
print(lq.get())
) h. z( B5 |, U4 O! s
print(lq.get())
2 M0 v8 ]9 j+ P9 n
: W$ N6 j5 {2 ?' M% T' q4 d8 ~
print("-------------queue.PriorityQueue----------------")/ K3 g" u1 C8 h% x+ P7 a
# 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
5 t/ s( N; S( _) _" X
pq = queue.PriorityQueue()3 j& b( x9 }) v/ }2 l: T
pq.put((1, "Jet"))
$ r5 r" H) \, ?! O' I) e
pq.put((3, "Jack"))
6 ?4 ~0 S) w5 A8 [- G
pq.put((2, "Judy"))
" Y, O5 d+ f( j9 G- X! h O
print(pq.get())4 p) L- a. F" O0 y6 \2 ^3 f4 y7 V0 f) X
print(pq.get())0 j7 `, _& ~6 u; f; u& u i" V
print(pq.get())

复制代码

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

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

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