from multiprocessing import Pool
if __name__=='__main__':
    manager = multiprocessing.Manager()
    # 父进程创建Queue,并传给各个子进程:
    q = manager().Queue() #共享数据管道
    p = Pool(10) #开线程池
    for i in range(5):
        p.apply_async(func_name, args=(i,))
    p.close()
    p.join()

多线程真垃圾!再也不用了!以后学习协程异步I/O





本文链接地址: python多进程之间数据交互

原创文章,转载请注明: 转载自Lz1y's Blog

发表评论

电子邮件地址不会被公开。 必填项已用*标注

This site uses Akismet to reduce spam. Learn how your comment data is processed.