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

admin

Python Queue 模块详解

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

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

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

将一个值从队列中取出
0 Y; W2 G1 B' x1 |( \. [  Lq.get()
调用队列对象的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)
$ D' G/ b/ I- F& `$ K3、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)

此包中的常用方法(q =queue.queue()):
# P6 Y! @7 G& V# g

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

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

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

q.get() 队首元素出队

q.empty() 如果队列为空，返回True,反之False
8 O* ]3 I6 s0 u% N6 ]q.full() 如果队列满了，返回True,反之False
% U$ ]' Z) ?. h3 q$ H3 J6 ]0 Gq.full 与 maxsize 大小对应
4 Y7 c) Q0 G+ H% [) }" m* w: Oq.get([block[, timeout]]) 获取队列，timeout等待时间
6 f3 ]+ b5 w# B% ~q.get_nowait() 相当q.get(False)
' a( o: }3 ]1 O1 `$ [' I+ I非阻塞 q.put(item) 写入队列，timeout等待时间
" x( g& L( d9 G1 T+ S" }q.put_nowait(item) 相当q.put(item, False)
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
q.join() 实际上意味着等到队列为空，再执行别的操作

代码实例 7810

1. import queue
   * j0 ^3 p% ~7 ?5 t
2. 
   , T  h6 R" u( W2 D+ V( Q+ p# H
3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
   6 g. c4 ~! {% ?1 A& |  S
4. print("-------------queue.Queue----------------")
   
5. # 线程消息队列,FIFO(先进先出)
   
6. q = queue.Queue()
   1 z2 v- h. S9 C, l; Q5 e
7. q.put("one")
   
8. q.put("two")
   $ S2 n# t; m* Y% s4 I8 Z( o
9. q.put("three")
   
10. print(q.get())
    3 E" x& L! M) Y' _% Z- u
11. print(q.get())
    
12. print(q.get())
    
13. try:
    1 H  s* F' G. G2 F$ h6 {3 K4 B
14.     # 队列中没有数据, 会阻塞。
    7 |* R0 y, \3 }# b% O. c+ l
15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    3 f3 v  p$ @8 F: |1 s% l- h
16.     print(q.get(timeout=3))
    : i8 h! I; Z  W+ s2 ]
17. except queue.Empty as q_e:
    
18.     print('queue empty')
      ~. L' m( d+ P; w' k+ l
19. 
    6 F/ |, v, H! w4 Y* v
20. print("-------------queue.LifoQueue----------------")
    1 Y$ p# n: h3 y
21. # 线程消息队列,LIFO(后进先出)
    % ]- w6 z+ K. r0 B' E/ n/ \) V
22. lq = queue.LifoQueue()
    : T" ?7 Y$ _2 E# E; ]7 V) l
23. lq.put("one")
    
24. lq.put("two")
      a- b  |- h. L/ p' b+ q' c
25. lq.put("three")
    
26. print(lq.get())
    . s) M+ A) G1 |5 {7 w4 A! Q5 `
27. print(lq.get())
    9 q1 O9 ]+ h( b  F
28. print(lq.get())
    
29. 
    
30. print("-------------queue.PriorityQueue----------------")
    8 X  y  C: d% @, D0 [9 B$ {
31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    . _' `. z6 [& G# G* ]6 r- Z8 D( m
32. pq = queue.PriorityQueue()
    2 h, J2 e0 K) e* {: N
33. pq.put((1, "Jet"))
    * n4 [" ]/ p( N+ r9 M0 k
34. pq.put((3, "Jack"))
    % Z& l0 ^4 j; h5 r. o2 z
35. pq.put((2, "Judy"))
    
36. print(pq.get())
    8 J8 j* [, R1 N- e) }; @, s1 s! W
37. print(pq.get())
    # ^+ R" ?( B, n9 {+ _, x* A! G/ t8 Y
38. print(pq.get())

复制代码