python 进程间通信

from multiprocessing import Process,Value,Array
def fun(n,a):
n.value = 3.1415927
for i in range(len(a)):
a[i] = -a[i]

if __name__ == '__main__':
num = Value('d',0.0)
arr = Array('i',range(10))
p = Process(target=fun,args=(num,arr))
p.start()
p.join()
print(num.value)
print(arr[:])

1 from multiprocessing import Process,Manager
2 def fun(d,l):
3     d[1]='1'
4     d[2]=2
5     d[0.25] = None
6     l.reverse()
7
8 if __name__ == '__main__':
9     with Manager() as manager:
10         d = manager.dict()
11         l = manager.list(range(10))
12         p = Process(target=fun,args=(d,l))
13         p.start()
14         p.join()
15         print(d)
16         print(l)

1 #！/usr/bin/env python
2 # -*- coding:utf-8 -*-
3 from multiprocessing import Pool
4 import time
5
6 def myfun(i):
7     time.sleep(2)
8     return i + 100
9 def end_call(arg):
10     print('end_call'+ str(arg))
11 if __name__ == '__main__':
12     p = Pool(5)
13     for i in range(10):
14         p.apply_async(func=myfun,args=(i,),callback=end_call)
15     print('end')
16     p.close()
17     p.join()