当前位置:主页 > python教程 > Python线程下queue(队列)模块的用法(附实例)

实例讲解Python线程下queue(队列)模块的用法

发布:2020-02-16 19:38:52 90


给大家整理一篇Python相关的编程文章,网友吕灵韵根据主题投稿了本篇教程内容,涉及到python、queue、队列、Python线程下queue(队列)模块的用法(附实例)相关内容,已被419网友关注,相关难点技巧可以阅读下方的电子资料。

Python线程下queue(队列)模块的用法(附实例)

本篇文章给大家带来的内容是关于Python线程下queue(队列)模块的用法,有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助。

 

queue模块实现了各种【多生产者-多消费者】队列。可用于在执行的多个线程之间安全的交换信息。

queue模块定义了3种不同的队列类。

3种不同的队列类

q=Queue(maxsize):创建一个FIFO(first-in first-out,先进先出)队列。maxsize是队列中金额以放入的项的最大数量。
如果省略maxsize参数或将它置为0,队列大小将无穷大。

q=LifoQueue(maxsize):创建一个LIFO(last-in first-out,后进先出)队列(栈)。

q=PriorityQueue(maxsize):创建一个优先级队列,其中项按照优先级从低到高依次排好。
使用这种队列时,项应该是(priority,data)形式的元组,其中priority时一个标识优先级的数字。

常用方法

q.size():返回队列的正确大小。因为其他线程可能正在更新此队列,所以此方法的返回数字不可靠。

q.empty():如果队列为空,返回True,否则返回False。

q.full():如果队列已满,返回True,否则返回False。

q.put(item,block,timeout):将item放入队列。
如果block设为True(默认值),调用者将被阻塞直到队列中出现可用的空闲位置为止。
如果block设为False,队列满时此方法将引发Full异常。

q.put_nowait(item):等价于q.put(item,False)

q.get(block,timeout):从队列中删除一项,然后返回这个项。
如果block设为True(默认值),调用者将阻塞,直到队列中出现可用的空闲为止。
如果block设为False,队列为空时将引发Empty异常。
timeout提供可选的超时值,单位为秒,如果超时,将引发Empty异常。

q.get_nowait():等价于get(0)

q.task_done():在队列种数据的消费者用来指示对于项的处理已经结束。如果使用此方法,那么从队列中删除的每一项都应该调用一次。

q.join():阻塞直到队列中的所有项均被删除和处理为止。一旦为队列中的每一项都调用了一次q.task_done()方法,此方法将会直接返回。

实例:

使用 队列一般可以简化多线程的程序。例如,可以使用共享队列将线程连接在一起,而不必依赖锁的保护。

在这种模型下,工作者线程一般充当数据的消费者。

from threading import Thread
from queue import Queue
class WorkerThread(Thread):
    def __init__(self,*args,**kwargs):
        Thread.__init__(self,*args,**kwargs)
        self.input_queue=Queue()

    def send(self,item):
        self.input_queue.put(item)
    def close(self):
        self.input_queue.put(None)
        self.input_queue.join()
    def run(self):
        while True:
            item=self.input_queue.get()
            if item is None:
                break
            #实际开发中,此处应该使用有用的工作代替
            print(item)
            self.input_queue.task_done()
        #完成,指示收到和返回哨兵
        self.input_queue.task_done()
        return

if __name__=="__main__":
    w=WorkerThread()
    w.start()
    w.send("php")
    w.send("中")
    w.send("文")
    w.send("网")
    w.close()

运行结果:

php
中
文
网

相关推荐:

全面解析python线程优先级队列(queue)原理

Python中使用Queue和Condition进行线程同步的方法

以上就是Python线程下queue(队列)模块的用法(附实例)的详细内容,更多请关注码农之家其它相关文章!


参考资料

相关文章

  • Python实现去除图片中指定颜色的像素功能示例

    Python实现去除图片中指定颜色的像素功能示例

    发布:2022-09-07

    为网友们分享了关于Python的教程,这篇文章主要介绍了Python实现去除图片中指定颜色的像素功能,结合具体实例形式分析了Python基于pil与cv2模块的图形载入、运算、转换等相关操作技巧,需要的朋友可以参考下


  • Python实现文字转语音并生成wav文件的实例代码

    发布:2019-12-19

    今天小编就为大家分享一篇使用Python实现文字转语音并生成wav文件的例子,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧


  • python画图并保存的方法

    发布:2020-07-10

    Python中使用不同的模块绘图保存方法不同,如使用matplotlib绘图使用savefig()保存图片,使用turtle绘图使用postscript()可以将图片保存到当前文件夹下。


  • Python如何使用logging为Flask增加logid

    发布:2022-09-07

    为网友们分享了关于Python的教程,这篇文章主要介绍了Python如何使用logging为Flask增加logid,帮助大家更好的理解和学习使用python,感兴趣的朋友可以了解下


  • 实例讲解Python中浮点型的基本内容

    发布:2022-06-18

    给大家整理了关于Python的教程,在本文里小编给大家整理了关于Python中浮点型的基本知识点内容,有兴趣的朋友们学习下。


  • Python中根据字符串调用函数的实现方法

    发布:2020-02-29

    字符串作为python中常用的数据类型,掌握字符串的常用方法十分必要。下面这篇文章主要给大家介绍了关于Python中通过字符串调用函数或方法的相关资料,需要的朋友可以参考借鉴,下面来一起


  • 实例分析Python多进程池 multiprocessing Pool的使用

    发布:2020-03-05

    这篇文章主要介绍了Python多进程池 multiprocessing Pool用法,结合实例形式分析了多进程池 multiprocessing Pool相关概念、原理及简单使用技巧,需要的朋友可以参考下


  • Python实现发送带有pdf附件的电子邮件

    发布:2023-04-04

    使用Python发邮件,是个简单的话题,可是如何可以优雅的轻松的群发邮件,并附加PDF附件,是很多小伙伴的日常工作。本文就来和大家分享一下实现方法,需要的可以参考一下


网友讨论