新大榭论坛

 找回密码
 注册

QQ登录

只需一步,快速开始

《新大榭》- 创大榭地方网络社区先锋品牌 新大榭始终专注于地方网络社区平台的建设 关于我们- [大记事]- 留言建议- [新手报道]

发布 .新大榭软件管家(Excel版) V6.0版 财务/仓库/生产/销售/采购/行政/人事/校园 .公告 - 客户 - 打赏 - 职场 - Excel - Python.

新大榭镜像-音乐-法律-图书-高中课堂-实验 广告是为了能更好的发展 [欢迎商家支持本站互利共赢] 广告位招租.首页黄金广告位等您来!联系 13566035181

查看: 296|回复: 0

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

 关闭 [复制链接]
发表于 2021-9-28 22:44:32 | 显示全部楼层 |阅读模式

马上注册,结交更多好友,享用更多功能,让你轻松玩转新大榭论坛!

您需要 登录 才可以下载或查看,没有账号?注册

x
Python Queue 模块详解
- P3 S: U4 e; {. B
Python3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块,是提供队列操作的模块,虽然简单易用,但是不小心的话,还是会出现一些意外。
创建一个“队列”对象
& w# O* P" H7 H5 kimport queue
' H. {( b& M8 I$ P( C- a0 w: Sq = queue.queue(maxsize = 10)
6 F( f6 P5 x7 {" s' p+ d. c0 Zqueue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。
将一个值放入队列中" d: U2 x! m4 B: S" N( Q
q.put(10)( k1 f& D3 P0 {
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为
% q: J2 x+ e! }$ b9 E0 i& W, q1 W1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。
将一个值从队列中取出
; h! b6 R, q% u( Nq.get()' E& c% b5 ?+ I& P, G3 R7 |3 |
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。
Python queue模块有三种队列及构造函数:
0 M) a# l* i2 j1 r* N1、Python queue模块的FIFO队列先进先出。     class queue.queue(maxsize)! o9 V: n9 t& H; v* k9 N
2、LIFO类似于堆,即先进后出。                         class queue.Lifoqueue(maxsize)
0 K9 s* S) w4 l% z8 N3 Z4 T1 T3、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)
此包中的常用方法(q =queue.queue()):9 |1 l; X) y1 \+ C: W
q.qsize() 返回队列的大小,即输出队列中元素的个数
q.queue.queue(5) 建立一个长度为5的队列q
q.put(5) 将数字5入队
q.get() 队首元素出队
q.empty() 如果队列为空,返回True,反之False) z3 B& G( Z  E, \7 J) W* [9 j3 R
q.full() 如果队列满了,返回True,反之False5 m! o. C. y3 ^6 L8 Y
q.full 与 maxsize 大小对应
0 C# p, E% c, X0 x; qq.get([block[, timeout]]) 获取队列,timeout等待时间
/ r# A+ J1 }  u' D" p7 c: b& G) zq.get_nowait() 相当q.get(False)
( l" D  s2 B3 W6 V3 I非阻塞 q.put(item) 写入队列,timeout等待时间, j# l1 Q8 @* f4 _. ~+ B$ E
q.put_nowait(item) 相当q.put(item, False): ?! ~  Y, Y$ `
q.task_done() 在完成一项工作之后,q.task_done() 函数向任务已经完成的队列发送一个信号) q/ u0 d) ]; E/ z5 p' A% v+ n
q.join() 实际上意味着等到队列为空,再执行别的操作

/ f1 Y" k; y5 Z. }' @. @代码实例 7810
" n2 u' `, c7 h. L
  1. import queue
    + d' k# F, G7 W- G

  2. 6 c" t2 L8 M9 D0 ?$ l
  3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大
    7 A) N% U( x) t: I0 `3 t
  4. print("-------------queue.Queue----------------")
    & M7 z9 Q) O$ E4 j: p/ R
  5. # 线程消息队列,FIFO(先进先出)3 f4 h4 v' ~5 W
  6. q = queue.Queue()5 H: s+ d0 W2 j. r
  7. q.put("one")- Y1 k" W, B0 |- E$ g# c
  8. q.put("two")
    + c1 I1 H3 o. g) }1 R5 R0 H1 [
  9. q.put("three")
    0 [' s3 C% M2 D) N) [1 k5 P, \
  10. print(q.get())4 I. E2 J/ [( ]6 f5 }* ~1 C
  11. print(q.get())
    4 w) x7 \; i3 ^% ^/ D( ^# L8 H1 O
  12. print(q.get())8 ^1 L7 T' y* Y; P+ H  S) ]
  13. try:
    + p3 T1 t, D  J* ?& I
  14.     # 队列中没有数据, 会阻塞。$ @! s7 D6 A* _. ?% \/ {4 ~
  15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    # G& o1 l; D( P) h5 R$ K
  16.     print(q.get(timeout=3))
    : |  j/ g6 E: a$ J3 \1 p
  17. except queue.Empty as q_e:
    9 v/ V& a% E+ I" L- S' ]
  18.     print('queue empty')  d+ ]* X* J5 r. o" d# ~
  19. + H% i" W9 k. ^! w: H8 E
  20. print("-------------queue.LifoQueue----------------")& a+ I* i- d/ l/ N7 O
  21. # 线程消息队列,LIFO(后进先出)
    % {1 x3 C3 F4 F
  22. lq = queue.LifoQueue()' w; ]" [) j2 g0 ?: `3 B
  23. lq.put("one")
    $ d4 E: X7 [8 _
  24. lq.put("two")
    + G( \9 X: U- n4 c- Z
  25. lq.put("three")
    ' U" W! v" \5 y- H6 v7 ^; L
  26. print(lq.get())/ s$ {" S  l, h2 \; W% H
  27. print(lq.get())* D, A* p7 j8 D# V& p" _6 z. a
  28. print(lq.get())4 u9 z9 H" d1 ^6 E: W

  29. % G. D5 `  W1 ^, u
  30. print("-------------queue.PriorityQueue----------------")
    7 Q! [. L# g( n# [* D9 S
  31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)4 B: @% u1 d: B! Y' [/ e  t# L" A3 y9 c
  32. pq = queue.PriorityQueue()$ U8 b; g) d2 u9 ]  _2 O
  33. pq.put((1, "Jet"))
    . S. ]2 p/ [& K8 A+ Y
  34. pq.put((3, "Jack")); D9 W1 J6 L( |5 |& I$ _
  35. pq.put((2, "Judy"))( ^0 ]8 Q/ Y7 C
  36. print(pq.get())9 L7 I% g' S3 w8 I) ]) O& ]2 Z& P
  37. print(pq.get()). s9 l. N. R2 I& c/ \$ Y
  38. print(pq.get())
复制代码

7810.py

1002 Bytes, 下载次数: 36, 下载积分: 财富 -1 点

新大榭Python学习社区培训、Excel业务指导、办公软件定制、网站建设;新大榭探索实验室欢迎您!http://lab.daxie.net.cn/
Q群推荐 大榭本地求职招聘QQ群,欢迎转发分享本地招聘信息资讯! 官方招聘1群(已满);官方招聘2群:315816937 *
您需要登录后才可以回帖 登录 | 注册

本版积分规则

文字版|小黑屋|新大榭 ( 浙ICP备16018253号-1 )|点击这里给站长发消息|

GMT+8, 2026-2-26 12:20 , Processed in 0.099960 second(s), 22 queries , Gzip On.

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

快速回复 返回顶部 返回列表