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

admin

Python Queue 模块详解

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

创建一个“队列”对象
/ x" F; g+ [7 R9 ?import queue
q = queue.queue(maxsize = 10)
queue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。

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

将一个值从队列中取出
q.get()
7 j/ ~! k2 F( Y( {3 Y- E6 Y. `% e: N调用队列对象的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)
1 U2 k  u$ r2 j7 @5 {9 i, `) Z3、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)

此包中的常用方法(q =queue.queue()):
- C3 X* m6 k  w+ D. e. O) A; H2 t

q.qsize() 返回队列的大小，即输出队列中元素的个数

q.queue.queue(5) 建立一个长度为5的队列q

q.put(5) 将数字5入队

q.get() 队首元素出队

q.empty() 如果队列为空，返回True,反之False
1 E5 S8 \$ H# U3 U% g6 t5 E$ Y! Zq.full() 如果队列满了，返回True,反之False
q.full 与 maxsize 大小对应
5 u! u' v* p1 @: lq.get([block[, timeout]]) 获取队列，timeout等待时间
5 [1 o; `4 D6 y, g: ]) pq.get_nowait() 相当q.get(False)
非阻塞 q.put(item) 写入队列，timeout等待时间
1 S1 A9 ], }: Z* z: S" Vq.put_nowait(item) 相当q.put(item, False)
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
" {/ a9 s' M2 r5 p* I6 o; Aq.join() 实际上意味着等到队列为空，再执行别的操作

代码实例 7810
9 u/ D/ Z% p  N7 U3 u2 Z' [

1. import queue
   & g7 L" W# g# `1 y8 h1 w
2. 
   " q4 Q# C5 }3 f$ g  u
3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
   
4. print("-------------queue.Queue----------------")
   ; O5 t8 r0 x; e. i' j( U. K
5. # 线程消息队列,FIFO(先进先出)
   ) B8 e, g. a5 n- n& n3 ~4 X( c! U
6. q = queue.Queue()
   % ^% b& ^6 {& b, [2 @
7. q.put("one")
   
8. q.put("two")
   2 r! k8 X9 T: a  B9 W% Y: p  Q) K
9. q.put("three")
   
10. print(q.get())
    
11. print(q.get())
    ; c; `, w9 A  I! t
12. print(q.get())
    
13. try:
    
14.     # 队列中没有数据, 会阻塞。
    # Q& _% O% c" F
15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    
16.     print(q.get(timeout=3))
    1 H6 P. y. a5 _. x7 \3 k
17. except queue.Empty as q_e:
    
18.     print('queue empty')
    5 q% ]$ p+ v6 b4 F4 |' B4 [, h) j4 H6 M2 W
19. 
    
20. print("-------------queue.LifoQueue----------------")
    
21. # 线程消息队列,LIFO(后进先出)
    
22. lq = queue.LifoQueue()
    ( P1 Q9 d) q' _& M
23. lq.put("one")
    ' Y; J/ R1 q, p6 ~
24. lq.put("two")
    ! F/ i2 c1 n( C1 h* x# l/ Q
25. lq.put("three")
    
26. print(lq.get())
    
27. print(lq.get())
    
28. print(lq.get())
      P& l* c( W# _  X& w
29. 
    ( j% \2 O* N! s
30. print("-------------queue.PriorityQueue----------------")
    
31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    7 J  Q' M, X9 j% l5 m
32. pq = queue.PriorityQueue()
    " I) Z/ \; q# ^+ q& t: _
33. pq.put((1, "Jet"))
    
34. pq.put((3, "Jack"))
    5 a( q. ^& F5 J9 ]6 s2 d* D
35. pq.put((2, "Judy"))
    6 M6 s/ W4 n: C# v3 V
36. print(pq.get())
    . }( y% H+ a' E/ s: C# S
37. print(pq.get())
    
38. print(pq.get())

复制代码