python Pool並行執行

# -*- coding: utf-8 -*-
import time
from multiprocessing import Pool
def run(fn):
  #fn: 函數參數是數據列表的一個元素
  time.sleep(1)
  print(fn*fn)

if __name__ == "__main__":
  testFL = [1,2,3,4,5,6]
  print ('順序:') #順序執行(也就是串行執行，單進程)
  s = time.time()
  for fn in testFL:
    run(fn)
  t1 = time.time()
  print ("順序執行時間：", int(t1 - s))

  print ('concurrent:')  #創建多個進程，並行執行
  pool = Pool(10)  #創建擁有10個進程數量的進程池
  #testFL:要處理的數據列表，run：處理testFL列表中數據的函數
  pool.map(run, testFL)
  pool.close() #關閉進程池，不再接受新的進程
  pool.join() #主進程阻塞等待子進程的退出
  t2 = time.time()
  print ("並行執行時間：", int(t2-t1))

執行結果：