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
    
  • 相关阅读:
    企业IT管理说:全自动就一定是最好的吗?
    银行爱“IOE”爱得有多深
    谷歌数据中心
    屏蔽爬虫
    ,net运行框架
    视频格式
    HTTP协议
    IE的体系和webrowser
    jsp请求由servlet响应的方式
    Web请求响应简单整理
  • 原文地址:https://www.cnblogs.com/aden668/p/11528271.html
Copyright © 2011-2022 走看看