Python 队列(Queue) Demo

以你之姓@ 2022-05-30 00:21 143阅读 0赞

> Python的多线程有个队列模块Queue  
> 这个模块就相当于创建一个线程池。举一个例子说明。一下这个Queue，比如我每天都去的吃的乔晨粗粮包子店。假如这个包子店的锅炉一次只能蒸100个包子，那就意味着面点师傅只要做满了100个就没办法做了，等着消费者来将里面消费到一定程度之后重新开始做。  
> 运用到Python就是这个Queue就是那个锅炉，容器。将线程生产出来的数据放到这个容器当中，通过queue.put()将数据放到容器中。，先进先出，然后消费者从这个容器中拿数据，queue.get()获取数据

队列实现生产者消费者模型。  
这个模型大概就是有生产者生产包子，生产的包子放到Quque当中，消费者再从Queue当中取包子。

import threading
    import time
    
    
    # 生产者函数
    def producers(name, que):
        while True:
            if q.qsize < 10 
                # put方法用于往队列放数据
                que.put('包子')
                print u'%s:生产了一个包子' % name
            time.sleep(random.randrange(5))
    
    def consumers(name, que):
        while True:
            try:
                #get 方法取出数据, get_nowait 如果队列中没有数据则就报错
                que.get_nowait('包子')
                print u'%s: 消费了一个包子' %s name
            except Exception:
                print u'没有包子了'
            time.sleep(random.randrange(3))
    
    q = Que.Que()
    # 使用两个线程生产
    p1 = threading.Thread(target=producers, args=(u'厨师1', q))
    p2 = thread.Thread(target=producers, args=(u'厨师2', q))
    p1.start()
    p2.start()
    # 两个线程是消费者
    c1 = thread.Thread(target=consumers, args=(u'消费者1', q))
    c1 = thread.Thread(target=consumers, args=(u'消费者2', q))
    c1.start()
    c1.start()

发表评论取消回复

表情：

评论列表（有 0 条评论，143人围观）

还没有评论，来说两句吧...

相关阅读

相关 python队列溢出_Python queue队列

Queue Queue是python标准库中的线程安全的队列(FIFO)实现,提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者线程之间的信息传递

今天药忘吃喽~/ 2022年11月01日 00:59/ 0 赞/ 110 阅读

相关 Queue队列

Queue队列概述队列是一个典型的先进先出（FIFO）的容器。即从容器的一端放入事物，从另一端取出，并且事物放入的顺序与取出的顺序是相同的。队列常被当作一种可靠

缺乏、安全感/ 2022年06月05日 21:10/ 0 赞/ 209 阅读

相关 Python 队列(Queue) Demo

> Python的多线程有个队列模块Queue > 这个模块就相当于创建一个线程池。举一个例子说明。一下这个Queue，比如我每天都去的吃的乔晨粗粮包子店。假如这个包子店的

以你之姓@/ 2022年05月30日 00:21/ 0 赞/ 144 阅读

相关队列Queue

队列是一种数据结构，它只允许在队列尾部（rear）加人一个元素，和从队列头部（front）移除一个元素。进行插入操作的端称为队尾，进行删除操作的端称为队头。队列中没有元素时，称

我就是我/ 2022年02月24日 17:29/ 0 赞/ 276 阅读

相关 Queue--队列

队列（Queue）和栈不同，队列是只允许在一端插入，在另一端进行删除的线性表，所有的插入操作都在队尾进行，删除操作则在队头进行。入队和出队顺序一样。由于数组在删除元素的时候

淩亂°似流年/ 2022年02月03日 16:25/ 0 赞/ 280 阅读

相关 Queue队列

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] /\\ \ 在java5中新增加了java.util

淩亂°似流年/ 2022年01月16日 01:31/ 0 赞/ 279 阅读

相关队列Queue

队列什么是队列？队列的种类单队列循环队列 Java集合框架中的Queue Queue方法介绍 add

蔚落/ 2021年11月11日 04:04/ 0 赞/ 335 阅读

相关 python queue - 同步队列类

参考 [官网][Link 1] queue 模块 queue 模块实现多生产者，多消费者队列。当必须在 ==多个线程之间安全地交换信息== 时，它在线程编程中特别

我就是我/ 2021年10月26日 14:26/ 0 赞/ 238 阅读

相关 Python模块-queue队列模块

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 队列方法 q = queue.Queue().pu

左手的ㄟ右手/ 2021年09月20日 05:20/ 0 赞/ 434 阅读

相关 queue 队列

import java.util.ArrayDeque; import java.util.PriorityQueue; / 2017-02-

￡神魔★判官ぃ/ 2021年09月11日 07:16/ 0 赞/ 364 阅读