欢迎光临
我们一直在努力

Python多进程(multiprocessing)共享变量

Python多进程(multiprocessing)共享变量

#!/usr/bin/env python2
# coding: utf8
import multiprocessing

def foo(h,context):
    if h%2 == 0:
        print (h)
    else:
        context.append(h)

if __name__ == "__main__":
    ## 设置共享list
    con = multiprocessing.Manager().list()
    ## 设置进程池大小
    p = multiprocessing.Pool(2)
    for i in range(18):
        # con = multiprocessing.Manager().list()
        p.apply_async(foo,args=(i,con))
    p.close()
    p.join()
    print con
赞(0)
【声明】:本博客不参与任何交易,也非中介,仅记录个人感兴趣的主机测评结果和优惠活动,内容均不作直接、间接、法定、约定的保证。访问本博客请务必遵守有关互联网的相关法律、规定与规则。一旦您访问本博客,即表示您已经知晓并接受了此声明通告。