新大榭论坛

 找回密码
 注册

QQ登录

只需一步,快速开始

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

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

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

查看: 266|回复: 0

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

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

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

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

x
Python Queue 模块详解
$ R* Z: q, _7 K
Python3中队列是线程间最常用的交换数据的形式。Queue模块python3内置的标准模块,是提供队列操作的模块,虽然简单易用,但是不小心的话,还是会出现一些意外。
创建一个“队列”对象0 u7 A' c% x4 e7 s
import queue
1 h% Q; t  V: ]# k0 O, ~1 aq = queue.queue(maxsize = 10)' k) }  y7 k6 p2 z1 Q
queue.queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过queue的构造函数的可选参数maxsize来设定队列长度。如果maxsize小于1就表示队列长度无限。
将一个值放入队列中
/ U2 T- g" x8 \  t: T: Q- ~q.put(10)% {& M+ H) ~+ h
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数,第一个item为必需的,为插入项目的值;第二个block为可选参数,默认为& ^- p7 G3 H4 c& p& b
1。如果队列当前为空且block为1,put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0,put方法将引发Full异常。
将一个值从队列中取出
. B* y6 O( [/ `) {4 `& ~q.get()) H. J% _' r( K& X& s
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block,默认为True。如果队列为空且block为True,get()就使调用线程暂停,直至有项目可用。如果队列为空且block为False,队列将引发Empty异常。
Python queue模块有三种队列及构造函数:
3 A; Y: V) \5 _5 H1、Python queue模块的FIFO队列先进先出。     class queue.queue(maxsize)4 }0 T5 @3 P+ I8 z. }7 z0 C
2、LIFO类似于堆,即先进后出。                         class queue.Lifoqueue(maxsize)& D* @: ^2 G2 q2 C9 y
3、还有一种是优先级队列级别越低越先出来。    class queue.Priorityqueue(maxsize)
此包中的常用方法(q =queue.queue()):" ?: q/ \2 {6 N% n
q.qsize() 返回队列的大小,即输出队列中元素的个数
q.queue.queue(5) 建立一个长度为5的队列q
q.put(5) 将数字5入队
q.get() 队首元素出队
q.empty() 如果队列为空,返回True,反之False: Y: q5 Q$ L0 H- p8 S- C2 P
q.full() 如果队列满了,返回True,反之False
) D/ @: f* R0 |' Yq.full 与 maxsize 大小对应
  N+ W! |8 S, c: T8 ]3 }4 @- m5 |q.get([block[, timeout]]) 获取队列,timeout等待时间
" h$ P4 e5 Q) C7 V3 v# u7 oq.get_nowait() 相当q.get(False)
( P6 o" B+ r  Z/ ~* N" V非阻塞 q.put(item) 写入队列,timeout等待时间
( Y+ D2 z7 k, E# ]- ]8 w  A4 X7 W. w; Aq.put_nowait(item) 相当q.put(item, False)
2 N: G+ w: D2 L" K3 q. A8 ~- X; eq.task_done() 在完成一项工作之后,q.task_done() 函数向任务已经完成的队列发送一个信号
* C) W) u3 R1 E7 p8 N6 `- v! wq.join() 实际上意味着等到队列为空,再执行别的操作
1 I* j% U0 l# K5 x0 L2 r  Z) t( t
代码实例 7810
) D9 m+ p: z1 b. K! c
  1. import queue: _' @  y) k- @6 D$ i9 I5 B

  2. # x5 ]3 Q7 ~/ d! |
  3. # 以下三个队列都可以设置最大长度maxsize,默认是无限大& a  S! Z1 }, Y
  4. print("-------------queue.Queue----------------")4 w; Y6 o" W# w5 L' X; P& t$ b
  5. # 线程消息队列,FIFO(先进先出)
    4 `$ z8 \  \" ~" O+ j
  6. q = queue.Queue(): Q2 ~$ I) F, p, Y& d" H
  7. q.put("one")
    2 R) j% N) x, M* D0 T
  8. q.put("two")
    7 y$ j6 }9 e2 f& k
  9. q.put("three")' j& u' P& [- j& u& }/ a. q
  10. print(q.get())# b" m* M) C* b1 D+ {6 o' f
  11. print(q.get())( ?* q" i: r/ J: m! W3 l" N% s
  12. print(q.get())
    " Y, n/ ^8 Y5 O& h
  13. try:# z( m0 I2 v* e! w. L$ H2 d
  14.     # 队列中没有数据, 会阻塞。) W5 V& v' h4 f4 P; \8 h! _: Z  |
  15.     # 阻塞时间到了还没有数据 抛出 queue.Empty 异常
    # c# T5 m* d" {
  16.     print(q.get(timeout=3)): n/ w; m- I) x% p0 X% W
  17. except queue.Empty as q_e:
    1 O  ~2 C  c+ V) m
  18.     print('queue empty')
    4 f, z) m( P5 S7 o0 d% q9 t- ^
  19. ) }; `) t: D' g- [% }0 ]3 J8 c
  20. print("-------------queue.LifoQueue----------------"), V: O* j4 I7 m
  21. # 线程消息队列,LIFO(后进先出)
      T! ?* E' y+ ?2 Y3 G8 Q0 \
  22. lq = queue.LifoQueue(); Z3 G$ o9 j$ d
  23. lq.put("one")
    - o( }* A4 C6 J7 j3 V
  24. lq.put("two")% T# [6 [) T: X' s
  25. lq.put("three")
    3 i5 H) f( L3 E" Z: b6 G
  26. print(lq.get())0 b/ S; d3 v; S2 ], j8 `5 C9 }0 n2 t
  27. print(lq.get())7 J3 g' n& D+ o$ t
  28. print(lq.get())
    1 Q  Y8 `6 \+ b/ t3 H

  29. ) Y! i5 C6 n" n: o7 f( G) z+ l9 z
  30. print("-------------queue.PriorityQueue----------------")
    6 ]( G- h6 d* m* M5 `! V  Q
  31. # 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
    5 X$ a, r( ]% G- _7 P% H5 c+ {
  32. pq = queue.PriorityQueue()
    " c% _2 a7 D1 [4 P) @
  33. pq.put((1, "Jet"))9 e' x% ]* R0 E- f) n; e0 j
  34. pq.put((3, "Jack"))
    + Q0 K1 M# U) e" t- N
  35. pq.put((2, "Judy"))+ {- M8 ~# @6 M
  36. print(pq.get())
    3 j6 ]* S2 ~  X+ Q
  37. print(pq.get())
    " K5 x2 v, E# u1 K
  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-1-1 20:06 , Processed in 0.091879 second(s), 22 queries , Gzip On.

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

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