|
|
马上注册,结交更多好友,享用更多功能,让你轻松玩转新大榭论坛!
您需要 登录 才可以下载或查看,没有账号?注册
x
Python Queue 模块详解
- P3 S: U4 e; {. BPython3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块,是提供队列操作的模块,虽然简单易用,但是不小心的话,还是会出现一些意外。 创建一个“队列”对象
& w# O* P" H7 H5 kimport queue
' H. {( b& M8 I$ P( C- a0 w: Sq = queue.queue(maxsize = 10)
6 F( f6 P5 x7 {" s' p+ d. c0 Zqueue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。 将一个值放入队列中" d: U2 x! m4 B: S" N( Q
q.put(10)( k1 f& D3 P0 {
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为
% q: J2 x+ e! }$ b9 E0 i& W, q1 W1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。 将一个值从队列中取出
; h! b6 R, q% u( Nq.get()' E& c% b5 ?+ I& P, G3 R7 |3 |
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。 Python queue模块有三种队列及构造函数:
0 M) a# l* i2 j1 r* N1、Python queue模块的FIFO队列先进先出。 class queue.queue(maxsize)! o9 V: n9 t& H; v* k9 N
2、LIFO类似于堆,即先进后出。 class queue.Lifoqueue(maxsize)
0 K9 s* S) w4 l% z8 N3 Z4 T1 T3、还有一种是优先级队列级别越低越先出来。 class queue.Priorityqueue(maxsize) 此包中的常用方法(q =queue.queue()):9 |1 l; X) y1 \+ C: W
q.qsize() 返回队列的大小,即输出队列中元素的个数 q.queue.queue(5) 建立一个长度为5的队列q q.put(5) 将数字5入队 q.empty() 如果队列为空,返回True,反之False) z3 B& G( Z E, \7 J) W* [9 j3 R
q.full() 如果队列满了,返回True,反之False5 m! o. C. y3 ^6 L8 Y
q.full 与 maxsize 大小对应
0 C# p, E% c, X0 x; qq.get([block[, timeout]]) 获取队列,timeout等待时间
/ r# A+ J1 } u' D" p7 c: b& G) zq.get_nowait() 相当q.get(False)
( l" D s2 B3 W6 V3 I非阻塞 q.put(item) 写入队列,timeout等待时间, j# l1 Q8 @* f4 _. ~+ B$ E
q.put_nowait(item) 相当q.put(item, False): ?! ~ Y, Y$ `
q.task_done() 在完成一项工作之后,q.task_done() 函数向任务已经完成的队列发送一个信号) q/ u0 d) ]; E/ z5 p' A% v+ n
q.join() 实际上意味着等到队列为空,再执行别的操作
/ f1 Y" k; y5 Z. }' @. @代码实例 7810
" n2 u' `, c7 h. L- import queue
+ d' k# F, G7 W- G -
6 c" t2 L8 M9 D0 ?$ l - # 以下三个队列都可以设置最大长度maxsize,默认是无限大
7 A) N% U( x) t: I0 `3 t - print("-------------queue.Queue----------------")
& M7 z9 Q) O$ E4 j: p/ R - # 线程消息队列,FIFO(先进先出)3 f4 h4 v' ~5 W
- q = queue.Queue()5 H: s+ d0 W2 j. r
- q.put("one")- Y1 k" W, B0 |- E$ g# c
- q.put("two")
+ c1 I1 H3 o. g) }1 R5 R0 H1 [ - q.put("three")
0 [' s3 C% M2 D) N) [1 k5 P, \ - print(q.get())4 I. E2 J/ [( ]6 f5 }* ~1 C
- print(q.get())
4 w) x7 \; i3 ^% ^/ D( ^# L8 H1 O - print(q.get())8 ^1 L7 T' y* Y; P+ H S) ]
- try:
+ p3 T1 t, D J* ?& I - # 队列中没有数据, 会阻塞。$ @! s7 D6 A* _. ?% \/ {4 ~
- # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
# G& o1 l; D( P) h5 R$ K - print(q.get(timeout=3))
: | j/ g6 E: a$ J3 \1 p - except queue.Empty as q_e:
9 v/ V& a% E+ I" L- S' ] - print('queue empty') d+ ]* X* J5 r. o" d# ~
- + H% i" W9 k. ^! w: H8 E
- print("-------------queue.LifoQueue----------------")& a+ I* i- d/ l/ N7 O
- # 线程消息队列,LIFO(后进先出)
% {1 x3 C3 F4 F - lq = queue.LifoQueue()' w; ]" [) j2 g0 ?: `3 B
- lq.put("one")
$ d4 E: X7 [8 _ - lq.put("two")
+ G( \9 X: U- n4 c- Z - lq.put("three")
' U" W! v" \5 y- H6 v7 ^; L - print(lq.get())/ s$ {" S l, h2 \; W% H
- print(lq.get())* D, A* p7 j8 D# V& p" _6 z. a
- print(lq.get())4 u9 z9 H" d1 ^6 E: W
-
% G. D5 ` W1 ^, u - print("-------------queue.PriorityQueue----------------")
7 Q! [. L# g( n# [* D9 S - # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)4 B: @% u1 d: B! Y' [/ e t# L" A3 y9 c
- pq = queue.PriorityQueue()$ U8 b; g) d2 u9 ] _2 O
- pq.put((1, "Jet"))
. S. ]2 p/ [& K8 A+ Y - pq.put((3, "Jack")); D9 W1 J6 L( |5 |& I$ _
- pq.put((2, "Judy"))( ^0 ]8 Q/ Y7 C
- print(pq.get())9 L7 I% g' S3 w8 I) ]) O& ]2 Z& P
- print(pq.get()). s9 l. N. R2 I& c/ \$ Y
- print(pq.get())
复制代码 |
-
-
7810.py
1002 Bytes, 下载次数: 36, 下载积分: 财富 -1 点
|