|
马上注册,结交更多好友,享用更多功能,让你轻松玩转新大榭论坛!
您需要 登录 才可以下载或查看,没有账号?注册
x
Python Queue 模块详解
' t* t2 ^/ j- {+ ` SPython3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块,是提供队列操作的模块,虽然简单易用,但是不小心的话,还是会出现一些意外。 创建一个“队列”对象
! ?/ |' @$ ]2 ?1 himport queue- C4 P7 K* w! s$ j8 y8 _; J2 q6 `; J
q = queue.queue(maxsize = 10)7 o; v2 u. C% }3 q; E
queue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。 将一个值放入队列中
. J$ v4 u7 F: K$ c/ f' bq.put(10)4 r2 z g# P' r9 X7 n' A% V
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为
" S5 d- L1 _; Q& a# A) t4 |8 S1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。 将一个值从队列中取出2 R8 Z& N; G( l
q.get(). N3 \7 S. ]% `' D, Z
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。 Python queue模块有三种队列及构造函数:0 E2 u z: a' t! m
1、Python queue模块的FIFO队列先进先出。 class queue.queue(maxsize). w- @% l5 p7 S( I% j% k
2、LIFO类似于堆,即先进后出。 class queue.Lifoqueue(maxsize)* f3 q' Y% [2 f0 b3 n2 c; |
3、还有一种是优先级队列级别越低越先出来。 class queue.Priorityqueue(maxsize) 此包中的常用方法(q =queue.queue()):; k8 F! |: d. |! F% F4 D H1 ?
q.qsize() 返回队列的大小,即输出队列中元素的个数 q.queue.queue(5) 建立一个长度为5的队列q q.put(5) 将数字5入队 q.empty() 如果队列为空,返回True,反之False
% l; z7 F# c7 |0 M- Gq.full() 如果队列满了,返回True,反之False
5 l! u. m. \- Y& L% s+ b; Vq.full 与 maxsize 大小对应/ I( N) t' m: }+ c
q.get([block[, timeout]]) 获取队列,timeout等待时间" A% G) o1 n) r0 L
q.get_nowait() 相当q.get(False)
1 N+ ]/ B. p+ H& ?, O, k非阻塞 q.put(item) 写入队列,timeout等待时间
/ P! G& }% @5 C- t# E) I* qq.put_nowait(item) 相当q.put(item, False)
0 T! S3 d4 f9 c$ qq.task_done() 在完成一项工作之后,q.task_done() 函数向任务已经完成的队列发送一个信号2 P! }8 G8 M3 k
q.join() 实际上意味着等到队列为空,再执行别的操作
# a& T/ |* N* H: J$ o代码实例 7810
+ E7 }- l K: ]: r- import queue8 j/ |2 V$ ?% P+ d0 D, V
-
4 ^6 A9 c# C7 b7 ?+ f2 [0 N% k - # 以下三个队列都可以设置最大长度maxsize,默认是无限大
: e: U. E `+ G" {" _" Z& b - print("-------------queue.Queue----------------")
0 }& `- \. X# N/ I$ T: l; Z* ` - # 线程消息队列,FIFO(先进先出)
( W2 { w& H# N - q = queue.Queue()% J' B' t: Z4 e8 \* T0 j1 o8 I
- q.put("one")4 u3 |% ^( Z( L1 ~3 f J, k' X8 ?
- q.put("two")
$ I. H1 d) f0 u; p. ]3 r3 M - q.put("three")
$ e$ Q$ A9 O2 M: J" {5 x - print(q.get())3 N- T7 L( q) z! y( m# ?: `( U2 ^
- print(q.get())
# h. a7 `" l3 E; O$ m$ i& } - print(q.get())( J! [2 K r) |/ ?: R0 \& w6 i
- try:1 W, ^, E }* i
- # 队列中没有数据, 会阻塞。$ m8 ^& Y+ Y: \# @! X- r$ i' x
- # 阻塞时间到了还没有数据 抛出 queue.Empty 异常# L; [1 f& Y2 ]; b5 @
- print(q.get(timeout=3))) [/ ~. @+ N; K6 Y4 n/ L
- except queue.Empty as q_e:
) r, C5 J; r% D' r4 m- E- d$ L - print('queue empty')6 a. M% v5 V: w: |8 u7 J, i/ ?
-
5 u ^+ E1 H4 T8 K8 e( I' B8 L - print("-------------queue.LifoQueue----------------")5 G1 ~& A4 b; {6 |/ v% U6 S# p
- # 线程消息队列,LIFO(后进先出)
8 l& i0 Q9 b/ N6 a - lq = queue.LifoQueue()8 j* R2 ~) J( ]- T/ o7 R6 r
- lq.put("one")
/ Q/ n+ M8 V% S8 _& n6 o% R - lq.put("two")( Y$ {/ Y' ~1 u1 [" ~2 N" p
- lq.put("three")9 J+ m) Z4 K- X6 E& D
- print(lq.get())) n! d, n2 K+ s2 O
- print(lq.get())
+ [4 _( W) }, `- e r1 X$ f( E$ U - print(lq.get())/ H9 V$ l# h7 B8 |% r; @
-
/ ]0 c- _; |6 n* t2 |% f - print("-------------queue.PriorityQueue----------------"), S$ Z/ B0 ?; J0 b0 n
- # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高) d2 p' T" X0 m. ~8 j
- pq = queue.PriorityQueue()
# P( o+ A, R, F( o- u3 t2 \1 \. ? - pq.put((1, "Jet"))
* ?" k7 x- k1 Q" j) y! a* r u- C$ _4 h - pq.put((3, "Jack"))& @+ z8 D" Z O. k+ |( z/ [
- pq.put((2, "Judy"))
9 V. m, o( ]( y$ W4 q- O K5 B% X - print(pq.get())
+ V2 b! \4 J; G9 J - print(pq.get())
9 _0 u. y& A& F) G& `7 x/ e - print(pq.get())
复制代码 |
|