|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
#_*_coding:utf-8_*_import time
from multiprocessing import Pool
from threading import Thread
def func1(fn):
time.sleep(1)
return fn * fn
if __name__ == "__main__":
a = [1,2,3,4,5,6]
print "顺序执行的方式开始..."
s = time.time()
for i in a:
func1(i)
el = time.time()
print "顺序执行时间为:",int(el - s)
print "创建多个进程，并行执行开始"
pool = Pool(5) #创建拥有5个进程数量的进程池,也就是说可以同时跑5个线程
p1 = pool.map(func1,a)
pool.close() #关闭进程池，不再接受新的进程
pool.join() #主进程阻塞等待子进程的退出
e3 = time.time()
print "多进程并行时间为:", int(e3 - el)
print p1
|
本文转自 TtrToby 51CTO博客，原文链接:http://blog.51cto.com/freshair/1899772