zoukankan      html  css  js  c++  java
  • python多进程通信

    #/usr/bin/env python
    #-*- coding:utf-8-*-
    
    import os
    import time
    import random
    from multiprocessing import Process,Queue
    
    def put_data(q,urls):
        print("Process %s Running..."%(os.getpid()))
        for url in urls:
            q.put(url)
            print("put %s in queue..."%url)
            time.sleep(random.randint(1,3))
    
    def get_data(q):
        print("Process %s Running..."%(os.getpid()))
        while True:
            url=q.get(True)
            print("get %s from queue..."%url)
    
    
    if __name__=='__main__':
        print("Main Process %s Running..."%(os.getpid()))
        q=Queue()
        writer_process1=Process(target=put_data,args=(q,['url1','url2','url3']))
        writer_process2=Process(target=put_data,args=(q,['url5','url6','url7']))
        writer_process3=Process(target=put_data,args=(q,['url5','url6','url7']))
        reader_process=Process(target=get_data,args=(q,))
    
        writer_process1.start()
        writer_process2.start()
        writer_process3.start()
        reader_process.start()

  • 相关阅读:
    Codeforces 1182E Product Oriented Recurrence 矩阵快速幂
    Codeforces 1182D Complete Mirror hash
    HDU
    HDU
    HDU
    HDU
    HDU
    HDU
    web框架之Vue渐进式框架-安装及入门
    web框架之Jqeury基本使用
  • 原文地址:https://www.cnblogs.com/boye169/p/14965902.html
Copyright © 2011-2022 走看看