Python之queue模块

queue模块实现了多生产者,多消费者的队列。当要求信息必须在多线程间安全交换,这个模块在同步线程编程时非常有用,Queue模块实现了所有要求的锁机制。内部实现是在抢占式线程加上临时锁,但是没有涉

大家好,又见面了,我是全栈君,今天给大家准备了Idea注册码。

  queue模块实现了多生产者,多消费者的队列。当要求信息必须在多线程间安全交换,这个模块在同步线程编程时非常有用 ,Queue模块实现了所有要求的锁机制。 

  内部实现是在抢占式线程加上临时锁,但是没有涉及如何去处理线程的重入

1. queue模块的内容

(1)class queue.Queue(maxsize = 0)

  构造一个FIFO队列,maxsize可以限制队列的大小。如果队列的大小达到了队列的上限,就会加锁,直到队列的内容被消费掉。如果maxsize的值小于等于0,那么队列的尺寸就是无限制的

(2)class queue.LifoQueue(maxsize = 0)

  构造一个LIFO队列

(3)class PriorityQueue(maxsize = 0)

  构造一个优先级队列,优先级最低的先出去,优先级最低的一般使用sorted(list(entries))[0]),典型加入的元素是一个元祖(优先级, 数据) 

(4)queue.empty异常

  只有非阻塞的时候,队列为空,取数据才会报异常

(5)queue.Full异常

  只有非阻塞的时候,队列满了,继续放数据才会出现异常

2. 队列对象的方法

(1)Queue.qsize()

  返回queue的近似值

  注意:qsize>0 不保证(get)取元素不阻塞。qsize< maxsize不保证(put)存元素不会阻塞

(2)Queue.empty()

  判断队列是否为空

(3)Queue.full()

  判断是否满了

(4)Queue.put(item, block=True, timeout=None):

  往队列里放数据,如果满了的话,blocking = False 直接报 Full异常;如果blocking = True,就是等一会,timeout必须为 0 或正数。None为一直等下去,0为不等,正数n为等待n秒还不能存入,报Full异常。

(5)Queue.put_nowait(item)

  往队列里存放元素,不等待

(6)Queue.get(item, block=True, timeout=None):

  从队列里取数据,如果为空的话,blocking = False 直接报 empty异常。如果blocking = True,就是等一会,timeout必须为 0 或正数。None为一直等下去,0为不等,正数n为等待n秒还不能读取,报empty异常。

(7)Queue.get_nowait(item)

  从队列里取元素,不等待

  put_nowait和get_nowait两个方法跟踪入队的任务是否被消费者daemon进程完全消费

 (8)Queue.task_done()

  表示队列中某个元素被消费进程或线程使用,消费结束发送信息。

(9)Queue.join()

  一直阻塞直到队列中的所有元素都被取出和执行

3. 简单示例

import threading
from queue import Queue

class ClosableQueue(Queue):
    SENTINEL = object()
    
    def close(self):
        self.put(SENTINEL)
        
    def __iter__(self):
        while True:
            item = self.get()
            try:
                if item is self.SENTINEL:
                    return 
                yield item
            finally:
                self.task_done()
                
class StoppabelWoker(threading.Thread):
    def __init__(self,func,in_queue,out_queue):
        self.func = func
        self.in_queue = in_queue
        self.out_queue = out_queue
    
    def run(self):
        for item in self.in_queue:
            result = self.func(item)
            self.out_queue.put(result)

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/120034.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 尝试HTML + JavaScript 编写Windows App

    尝试HTML + JavaScript 编写Windows App

  • Python自动化面试题(自动化测试面试基础问题)

    Python自动化测试面试题目汇总1、super是干嘛用的?在Python2和Python3使用,有什么区别?为什么要使用super?请举例说明。答:super用于继承父类的方法、属性。 super是新式类中才有的,所以Python2中使用时,要在类名的参数中写Object。Python3默认是新式类,不用写,直接可用。 使用super可以提高代码的复用性、可维护性。修改代码时,只需修改一处。 代码举例:classbaseClass:def.

  • 搭建自己的Android浏览器(一)[通俗易懂]

    搭建自己的Android浏览器(一)[通俗易懂]搭建自己的Android浏览器(一)最近尝试Android端开发,想开发一个自己的Android浏览器,根据自己的想法个性化定制,开博客用于记录和分享。Android开发环境搭建浏览器设想

  • ROS教程(五):OpenCV调用USB摄像头并发布topic(详细图文)

    ROS教程(五):OpenCV调用USB摄像头并发布topic(详细图文)前言ros教程:OpenCV调用usb摄像头创建功能包教程在ROS教程(三):创建程序包及节点(图文)已讲解,本文便不再细讲。

  • 什么是DDR3_DDR3 SDRAM

    什么是DDR3_DDR3 SDRAMODT是什么鬼?为什么要用ODT?在很多关于DDR3的博文和介绍中都没有将清楚。在查阅了很多资料并仔细阅读DDR3的官方标准(JESD79-3A)之后,总算有点了头绪,下面来整理整理。1、首先ODT是什么?ODT(On-DieTermination),是从DDR2SDRAM时代开始新增的功能。其允许用户通过读写MR1寄存器,来控制DDR3SDRAM中内部的终端电阻的连接或者断开。在DDR3…

  • PLSQL的使用「建议收藏」

    PLSQL的使用「建议收藏」PLSQL这个工具专门为oracle开发的(它只能连接oracle数据库)很多工具都可以连接oracle数据库(常用的有navicat、toad、plsql等)1.1 初次登录PLSQL

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号