|
|
马上注册,结交更多好友,享用更多功能,让你轻松玩转新大榭论坛!
您需要 登录 才可以下载或查看,没有账号?注册
x
Python Queue 模块详解
, Z$ [7 {' ~5 d* C4 _Python3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块,是提供队列操作的模块,虽然简单易用,但是不小心的话,还是会出现一些意外。 创建一个“队列”对象
: p+ W4 M& L7 H4 Uimport queue( G1 S( [2 ~ w7 @2 n
q = queue.queue(maxsize = 10)
9 N3 V' Q! B5 V, f; Tqueue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。 将一个值放入队列中
! V" M6 F( D s! e2 q9 G( @9 wq.put(10)
6 B+ Y" y+ k$ S) |( _调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为* C% j8 c+ K+ P7 J. K2 L Z; j2 A) D
1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。 将一个值从队列中取出" i m7 Q: g/ k& h& n
q.get()5 b) P) v5 k, Y* W
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。 Python queue模块有三种队列及构造函数:) W% [- s, I% L# E$ n6 }
1、Python queue模块的FIFO队列先进先出。 class queue.queue(maxsize)+ j4 r: a. N. t3 s7 f9 O ?
2、LIFO类似于堆,即先进后出。 class queue.Lifoqueue(maxsize)4 V# v6 ~$ K) `4 }% c+ c
3、还有一种是优先级队列级别越低越先出来。 class queue.Priorityqueue(maxsize) 此包中的常用方法(q =queue.queue()):
7 e. a7 v- Y* d q.qsize() 返回队列的大小,即输出队列中元素的个数 q.queue.queue(5) 建立一个长度为5的队列q q.put(5) 将数字5入队 q.empty() 如果队列为空,返回True,反之False
* c" [$ u2 W2 w* ~/ tq.full() 如果队列满了,返回True,反之False
% ~7 A4 @* i6 |q.full 与 maxsize 大小对应- ~+ E0 [; H" m! r* J! S2 ^. F
q.get([block[, timeout]]) 获取队列,timeout等待时间0 K) v& K6 j% c
q.get_nowait() 相当q.get(False)
; z3 M9 O3 E }9 l# u9 D- L非阻塞 q.put(item) 写入队列,timeout等待时间
+ ^0 i4 V' \: M {0 A1 Yq.put_nowait(item) 相当q.put(item, False)
0 R7 v7 F# I0 S. U$ ~q.task_done() 在完成一项工作之后,q.task_done() 函数向任务已经完成的队列发送一个信号2 f3 |+ l. m G4 L/ M
q.join() 实际上意味着等到队列为空,再执行别的操作
) @) B, t t- x0 y0 p
代码实例 7810& X& S7 J( D5 f& Q
- import queue
; E, |% D! U8 r+ T5 |3 d - ; |* o! H3 R+ U
- # 以下三个队列都可以设置最大长度maxsize,默认是无限大
: _ u- e& [; Y7 [, t& b# @ - print("-------------queue.Queue----------------")) G0 h6 L" t9 x6 u; ?9 s; s/ S
- # 线程消息队列,FIFO(先进先出); f( B* O# \/ L% _" @
- q = queue.Queue()
2 W8 {2 i& z7 V/ N7 ]3 d7 b8 ? - q.put("one")( D2 h' y) E! a
- q.put("two")) S0 [4 n1 N g) D+ E- H Q; n: J& ]' Y
- q.put("three")( e e* a( t' v' R$ n. Q" M6 ^# y
- print(q.get())
6 ]7 |1 b2 x- v; q# W, f - print(q.get()): O' C+ G0 R% j- H; W6 b2 Z
- print(q.get())
, R5 P. s2 N, D, _ - try:% N, T1 [+ @6 J6 d: W
- # 队列中没有数据, 会阻塞。) V8 R. S; Y8 _' A" v) G
- # 阻塞时间到了还没有数据 抛出 queue.Empty 异常 m9 ~$ N# W: n% P8 _: u& \ I
- print(q.get(timeout=3))
- N5 [' ~) k. ^) L4 v/ H - except queue.Empty as q_e:
- }: m" _6 q5 v. A" l1 S - print('queue empty')3 v5 i5 m- X! _1 D; t0 l. A
- 3 Z; u4 d* ]2 w+ O9 V& u
- print("-------------queue.LifoQueue----------------")
+ U5 u& S1 _- g0 T3 c; V - # 线程消息队列,LIFO(后进先出)) M5 U+ W; |& W" C( Q! x
- lq = queue.LifoQueue(); u, Z5 k, L; C# G( `9 n# V& C1 I
- lq.put("one")5 `% l' K. g8 x: |& {
- lq.put("two")2 v) h# o7 M, b, K0 T
- lq.put("three")
7 C. }# z8 M M9 I3 I - print(lq.get())
$ }& Y7 h) T( L6 x3 b - print(lq.get())6 O) y$ l* k8 h) ^* ]5 v& B
- print(lq.get())1 N! J6 v1 S: n1 a" E
-
+ m% i1 o( o6 H$ U* E - print("-------------queue.PriorityQueue----------------")
* Z. H4 y- ]6 Z! M5 I# E - # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)/ B( `+ N1 c- ?
- pq = queue.PriorityQueue()$ P( P" O4 c5 I- G' F
- pq.put((1, "Jet"))
8 [! P$ T; X$ ~$ W$ f3 d - pq.put((3, "Jack"))9 t8 a% |( L( ^2 t/ ?, p$ v
- pq.put((2, "Judy"))+ D+ b- [! ]" O$ Z3 C, S: n. w% G
- print(pq.get())
9 r) B3 w, b! T. P q - print(pq.get())
9 G' @$ D; k/ w& Q0 Z - print(pq.get())
复制代码 |
-
-
7810.py
1002 Bytes, 下载次数: 36, 下载积分: 财富 -1 点
|