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

admin

Python Queue 模块详解

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

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

将一个值放入队列中
0 |6 L+ Q" J7 a" A8 _5 W9 v% c4 q6 Z3 n# hq.put(10)
; E% `6 r# F: q, B" a1 Z调用队列对象的put()方法在队尾插入一个项目。put()有两个参数，第一个item为必需的，为插入项目的值；第二个block为可选参数，默认为
' Z) P* d% C. E% K2 J9 e. v* H, V1。如果队列当前为空且block为1，put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0，put方法将引发Full异常。

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

Python queue模块有三种队列及构造函数:
1 O. o3 q9 g6 Y( r+ R8 I8 h1、Python queue模块的FIFO队列先进先出。     class queue.queue(maxsize)
2、LIFO类似于堆，即先进后出。                         class queue.Lifoqueue(maxsize)
3、还有一种是优先级队列级别越低越先出来。    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
6 d5 o% s) d# Y+ X- u- ?q.full() 如果队列满了，返回True,反之False
' T$ ]8 \7 [9 B/ @6 F; ^) c/ Nq.full 与 maxsize 大小对应
: M( x' O- a1 H% _q.get([block[, timeout]]) 获取队列，timeout等待时间
q.get_nowait() 相当q.get(False)
3 ~1 ?* w! D4 G' }* f非阻塞 q.put(item) 写入队列，timeout等待时间
q.put_nowait(item) 相当q.put(item, False)
4 j4 N$ ?* J7 y) j1 Z  c( M5 Bq.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
: ^: M6 X* W6 H4 fq.join() 实际上意味着等到队列为空，再执行别的操作

代码实例 7810
( S" A3 ]0 R/ q( N# B& s

1. import queue
   
2. 
   
3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
   ; \( d. W$ M: N# u$ X/ u
4. print("-------------queue.Queue----------------")
   
5. # 线程消息队列,FIFO(先进先出)
   
6. q = queue.Queue()
   * |: y- p" d6 [! I+ F3 `  n+ s
7. q.put("one")
   
8. q.put("two")
   
9. q.put("three")
   4 t8 M# O8 T2 U2 `2 W8 V, {
10. print(q.get())
    ) ?) z" C) k' L8 U+ h8 r
11. print(q.get())
    
12. print(q.get())
    6 R/ A/ O6 q, _5 [3 B
13. try:
    2 d* q$ W4 g3 {5 M  K
14.     # 队列中没有数据, 会阻塞。
    3 N' t2 O  h: s9 x
15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    + C4 m$ D% w" Z& ?+ U
16.     print(q.get(timeout=3))
    
17. except queue.Empty as q_e:
    . v7 f' `6 L9 B. [5 V0 I8 [* y
18.     print('queue empty')
    & L/ {* K. x% F# E/ ]1 q" N2 }7 d
19. 
    ; |) V* w! X) D  w
20. print("-------------queue.LifoQueue----------------")
    
21. # 线程消息队列,LIFO(后进先出)
    * T% ^: S/ t2 G' H* I5 _
22. lq = queue.LifoQueue()
    / L* A" z4 I( Y9 ?( N
23. lq.put("one")
    * u; B0 W/ J0 K1 e
24. lq.put("two")
    
25. lq.put("three")
    " u* h' u' c$ ?' ?! `
26. print(lq.get())
    
27. print(lq.get())
    
28. print(lq.get())
    * @" D+ C; V  l. N$ Z& \) J
29. 
    
30. print("-------------queue.PriorityQueue----------------")
    * y/ X* E  M1 i6 m
31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    9 G" @7 G' U" y9 N4 ^1 q, `) `
32. pq = queue.PriorityQueue()
    ' f2 V8 O! Z* _. _2 C
33. pq.put((1, "Jet"))
    
34. pq.put((3, "Jack"))
    ' l5 Q7 l' K; U
35. pq.put((2, "Judy"))
    
36. print(pq.get())
    8 Y/ m- ?6 m- W' a3 F7 a
37. print(pq.get())
    
38. print(pq.get())

复制代码