<code>from multiprocessing import Pool
import time
import random
import os
def work(msg):
start = time.time()
print("work{}开始执行,id为{}".format(msg, os.getpid()))
time.sleep(random.random()*2)
stop = time.time()
print("work{}耗时{}.".format(msg, stop-start))
p = Pool()
for i in range(10):
# 非堵塞运行
p.apply_async(work, args=(i,))
# 堵塞进行
# p.apply(work, args=(i,))
print("开始")
p.close()
p.join()
print("结束")/<code>
- 线程实现
<code>import threading
import os
from time import sleep
def sorry(i):
print('say sorry {}'.format(i))
sleep(1)
if __name__ == '__main__':
for i in range(1,10):
t = threading.Thread(target=sorry, args=(i,))
t.start()/<code>
閱讀更多 程序員亮哥 的文章