python中进程数据共享

python进程数据共享

1. 共享一个队列

import multiprocessing
def task(args):
    q.put(args)
if __name__ == '__main__':
    q = multiprocessing.Queue()
    for i in range(10):
        p = multiprocessing.Process(target=task,args=(i,))
        p.start()
        p.join()
    v1 = q.get()
    print(v1)

2. 共享一个字典

def task(key,value):
    dic[key]=value

if __name__ == '__main__':
    m = multiprocessing.Manager()
    dic = m.dict()
    for i in range(10):
         p = multiprocessing.Process(target=task,args=(i,100))
         p.start()
         p.join()