zoukankan      html  css  js  c++  java
  • 测试joinablequeue

    测试joinablequeue

    问题
      在之前的生产者消费者模型中,生产者和消费者只有一个,

      那么生产者往队列里put几次,消费者就get几次,但是存在一个问题,

      生产者不一定只有一个,消费者也不一定只有一个,那么怎么确定生产者进程结束了,

      从而让消费者进程跟着一起结束成为一个问题(不然消费者还是一直处于get的阻塞状态,无法终止)

    解决办法
      1、通过joinablequeue类实例化出来的对象来代替之前queue实例化产生的进程间的队列

      2、q.join() 和 q.task_done()方法配合使用

        q.join方法可以让主进程进入阻塞状态,满足传入队列的数据put次数等于q.task_done传过来的信号次数才可以接着往下执行,

      3、所以为了让所有的生产者能生产完毕,主进程需要等这些子进程完毕才可以进入q.join的阻塞状态

      4、主进程等待子进程可以用到Process中的join方法,

      5、可以通过p.daemon = True把消费者进程设置为主进程的守护进程,那么主进程代码执行完,守护进程也会结束

        从而解决上面不知道生产者生产完毕而消费者不知道一直等待取值的问题

    from multiprocessing import Process,Queue,JoinableQueue
    
    
    q = JoinableQueue()
    
    q.put('zhao') # 放队列里一个任务
    q.put('qian')
    
    print(q.get())
    q.task_done() # 完成了一次任务
    print(q.get())
    q.task_done() # 完成了一次任务
    q.join() #计数器不为0的时候 阻塞等待计数器为0后通过
    
    # 想象成一个计数器 :put +1   task_done -1
    
  • 相关阅读:
    C# 串口调试助手源码
    C# 中 textBox 侧面滑条 属性
    C# 中 comboBox 禁止输入
    VS2015 下载 破解
    中国移动OnetNet云平台 GET指令使用
    JSON JsonArray和JsonObject学习资料
    sublime 添加 ConvertToUTF-8
    sublime 添加 颜色插件 colorcoder
    线程池
    爬虫中基本的多线程
  • 原文地址:https://www.cnblogs.com/aden668/p/11528271.html
Copyright © 2011-2022 走看看