<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>
閱讀更多 程序員亮哥 的文章