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

admin

Python Queue 模块详解
. }# e/ P  F6 X: V3 a6 C$ |& ?

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

创建一个“队列”对象
import queue
  F( Q; A$ H+ W6 o7 eq = queue.queue(maxsize = 10)
queue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。

将一个值放入队列中
2 C9 E4 k2 s  [' u9 {9 Cq.put(10)
( j  [6 p! z+ |3 v调用队列对象的put()方法在队尾插入一个项目。put()有两个参数，第一个item为必需的，为插入项目的值；第二个block为可选参数，默认为
1。如果队列当前为空且block为1，put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0，put方法将引发Full异常。

将一个值从队列中取出
1 T, U. S/ d$ [! [! o/ J6 r4 l- aq.get()
& `3 b( o* A4 J/ p调用队列对象的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)
  f* V5 q: H/ ~0 S7 Y/ i3、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)

此包中的常用方法(q =queue.queue()):
9 ]: x( `2 C+ |" }

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

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

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

q.get() 队首元素出队

q.empty() 如果队列为空，返回True,反之False
q.full() 如果队列满了，返回True,反之False
7 a6 M- Y6 T/ j1 zq.full 与 maxsize 大小对应
q.get([block[, timeout]]) 获取队列，timeout等待时间
' K" S/ {9 M3 N5 J% pq.get_nowait() 相当q.get(False)
. g; a/ x6 ?- G6 X' x  L( X' i非阻塞 q.put(item) 写入队列，timeout等待时间
q.put_nowait(item) 相当q.put(item, False)
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
q.join() 实际上意味着等到队列为空，再执行别的操作

# ^; a5 q" ^# ~& e0 P代码实例 7810
# w& u& x) L+ G

1. import queue
   ) h2 N2 P  e: _1 _7 _1 }5 P+ H9 @, X
2. 
   0 r, u  d0 n7 d: i4 Z2 z: @
3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
   7 s. ~" B" O5 A; x! L
4. print("-------------queue.Queue----------------")
   4 ]: `4 H' `0 y
5. # 线程消息队列,FIFO(先进先出)
   
6. q = queue.Queue()
   
7. q.put("one")
   5 M8 o% b% z& @; ?: ?7 P1 [3 s
8. q.put("two")
   
9. q.put("three")
   * G& G$ k- L+ d) W  N& x
10. print(q.get())
    
11. print(q.get())
    . F$ }4 n! d( E; }
12. print(q.get())
    
13. try:
    # j3 ^, d; @6 l: t" ]
14.     # 队列中没有数据, 会阻塞。
    " K- X5 Q! x# b( a! d
15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    
16.     print(q.get(timeout=3))
    5 m4 E' j) c8 w7 k) w( s6 N& K
17. except queue.Empty as q_e:
    3 ^8 F: v' \/ B7 k( @6 ^* x
18.     print('queue empty')
    " w/ o+ t; C% e- B, l0 }& N, G
19. 
    % u% P8 l) f8 }3 F
20. print("-------------queue.LifoQueue----------------")
    0 P% a/ m: c- w" M; N* q* t" r
21. # 线程消息队列,LIFO(后进先出)
    
22. lq = queue.LifoQueue()
    " L4 ]! v! C2 P  ?8 C8 f
23. lq.put("one")
    
24. lq.put("two")
    8 `) |0 m* f9 {: Q8 `9 L
25. lq.put("three")
    : A* b1 k+ j( Q/ a+ U
26. print(lq.get())
    
27. print(lq.get())
    
28. print(lq.get())
    + v$ I6 F3 T( L! Y
29. 
    
30. print("-------------queue.PriorityQueue----------------")
    
31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    ! {- c& g3 e4 q! K
32. pq = queue.PriorityQueue()
    
33. pq.put((1, "Jet"))
    
34. pq.put((3, "Jack"))
      F. U" V+ t, K! ?; m5 u; S
35. pq.put((2, "Judy"))
      r! O7 k5 [8 K, Y
36. print(pq.get())
    / L/ n% c# O3 X; \3 e% s% y3 u
37. print(pq.get())
    
38. print(pq.get())

复制代码