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

admin

Python Queue 模块详解

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

创建一个“队列”对象
import queue
q = queue.queue(maxsize = 10)
7 X4 U2 T" N3 w1 f$ P) u& C; kqueue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。

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

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

Python queue模块有三种队列及构造函数:
1、Python queue模块的FIFO队列先进先出。     class queue.queue(maxsize)
" C& q( Q, O' y- u. p2 r3 V: i6 `5 o2、LIFO类似于堆，即先进后出。                         class queue.Lifoqueue(maxsize)
( ^8 y; H' G/ g  X, V) Q: x9 O: g3、还有一种是优先级队列级别越低越先出来。    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
; _0 O  @" Q0 `6 {3 jq.full() 如果队列满了，返回True,反之False
q.full 与 maxsize 大小对应
  L- u0 O1 X& v! y9 d( fq.get([block[, timeout]]) 获取队列，timeout等待时间
q.get_nowait() 相当q.get(False)
. E9 t1 V) g! L- l0 n, @4 V非阻塞 q.put(item) 写入队列，timeout等待时间
q.put_nowait(item) 相当q.put(item, False)
. `! t8 F) d$ gq.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
: K6 [" H0 `: L+ k* Vq.join() 实际上意味着等到队列为空，再执行别的操作

6 {1 d. C! d; A4 ~1 c7 a* c代码实例 7810

1. import queue
   ; r2 m( W5 W8 _/ ~% A
2. 
   5 \) `8 ^" D; H7 D' ]1 k
3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
   
4. print("-------------queue.Queue----------------")
   
5. # 线程消息队列,FIFO(先进先出)
   ; v; A3 a, o  |7 Q4 H
6. q = queue.Queue()
   
7. q.put("one")
   0 \: e/ p2 v! b) [" V& P$ P) @: b: J
8. q.put("two")
   
9. q.put("three")
   
10. print(q.get())
    0 G* L. y1 O: a; z& w
11. print(q.get())
    ! D8 S0 ?4 h  I( s1 ?& F4 Y
12. print(q.get())
    
13. try:
    / ?  p, {- G# _) \8 i2 b
14.     # 队列中没有数据, 会阻塞。
    3 B' ^3 a; T, W
15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    
16.     print(q.get(timeout=3))
    5 ~& q$ u9 |9 ~# _7 d+ g
17. except queue.Empty as q_e:
    
18.     print('queue empty')
    . v/ ~; w# z# Y" r" @/ B3 A
19. 
    / g4 e* w1 T# x" N$ ]- R5 n' \" O
20. print("-------------queue.LifoQueue----------------")
    * ?9 i& C* u! M- y6 n
21. # 线程消息队列,LIFO(后进先出)
    $ w. X1 W  x1 l" m
22. lq = queue.LifoQueue()
    ' I7 R6 B  v8 L9 E5 `- R& _
23. lq.put("one")
    
24. lq.put("two")
    
25. lq.put("three")
    / k# @! I* M( J/ l2 V& T
26. print(lq.get())
    ' E$ Z7 b* @: }
27. print(lq.get())
    
28. print(lq.get())
    
29. 
    ) u" n! T; O+ G
30. print("-------------queue.PriorityQueue----------------")
    ) m. n( a( w, h
31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    9 K9 d- \" H0 X: O8 S- U: t  m
32. pq = queue.PriorityQueue()
    # i% w' x% S2 W8 N' V2 N4 T1 R
33. pq.put((1, "Jet"))
    0 ^3 @; X' s5 X8 c
34. pq.put((3, "Jack"))
    : f5 k# R! e. w/ a1 t
35. pq.put((2, "Judy"))
    
36. print(pq.get())
    " l  R/ c9 J  S! I. g
37. print(pq.get())
      y5 B7 o1 X- ], R. q+ n2 L' I2 [/ H
38. print(pq.get())

复制代码