python中的多进程

Python中的多进程使用

Multiprocessing进程池

1
2
3
4
5
6
7
8
9
10
11
from multiprocessing import Pool
def (msg):
print msg
pool = Pool(4)
jobs = []
for i in range(4):
jobs.append(pool.apply_async(run_func, (i, )))
pool.close()
pool.join()

Multiprocessing线程池

1
2
3
4
5
6
7
8
9
10
11
from multiprocessing.dummpy import Pool
def (msg):
print msg
pool = Pool(4)
jobs = []
for i in range(4):
jobs.append(pool.apply_async(run_func, (i)))
pool.close()
pool.join()