前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >python 多线程 fifo/lifo/priority队列(并行编程 9)

python 多线程 fifo/lifo/priority队列(并行编程 9)

作者头像
用户5760343
发布2019-07-30 11:06:07
8550
发布2019-07-30 11:06:07
举报
文章被收录于专栏:sktj

import queue

以下三个队列都可以设置最大长度maxsize,默认是无限大

print("-------------queue.Queue----------------")

线程消息队列,FIFO(先进先出)

q = queue.Queue() q.put("one") q.put("two") q.put("three") print(q.get()) print(q.get()) print(q.get()) try: # 队列中没有数据, 会阻塞。 # 阻塞时间到了还没有数据 抛出 queue.Empty 异常 print(q.get(timeout=3)) except queue.Empty as q_e: print('queue empty')

print("-------------queue.LifoQueue----------------")

线程消息队列,LIFO(后进先出)

lq = queue.LifoQueue() lq.put("one") lq.put("two") lq.put("three") print(lq.get()) print(lq.get()) print(lq.get())

print("-------------queue.PriorityQueue----------------")

线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)

pq = queue.PriorityQueue() pq.put((1, "Jet")) pq.put((3, "Jack")) pq.put((2, "Judy")) print(pq.get()) print(pq.get()) print(pq.get())

运行结果:

-------------queue.Queue---------------- one two three queue empty -------------queue.LifoQueue---------------- three two one -------------queue.PriorityQueue---------------- (1, 'Jet') (2, 'Judy') (3, 'Jack')

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019.07.27 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 以下三个队列都可以设置最大长度maxsize,默认是无限大
  • 线程消息队列,FIFO(先进先出)
  • 线程消息队列,LIFO(后进先出)
  • 线程消息队列,PriorityQueue(优先级的队列:数字越小优先级越高)
  • 运行结果:
相关产品与服务
消息队列 CMQ 版
消息队列 CMQ 版(TDMQ for CMQ,简称 TDMQ CMQ 版)是一款分布式高可用的消息队列服务,它能够提供可靠的,基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)中的信息传递,存储在可靠有效的 CMQ 队列中,防止消息丢失。TDMQ CMQ 版支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档