1、新模組
from concurrent.futures importthreadpoolexecutor
from concurrent.futures import processpoolexecutor
2、方法
"""執行緒數量一般是cpu個數*5
submit(函式名, 引數)
map(函式名, 可迭代物件)
obj.shutdown() 相當於obj.close()和obj.join()
obj.result() 獲取返回值
and_done_callback(函式),**函式
done() 檢視某個執行緒是否完成
"""
3、示例
importtime
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
(n)
return pow(n, 2)
t_pool = threadpoolexecutor(5) #
執行緒池中線程的數量
t_li =
for i in range(12):
ret = t_pool.submit(test1, i) #非同步#
print(ret.result())
t_pool.shutdown()
#相當於close()和join()方法
print('
adaf')
for t in
t_li:
print('
***', t.result())
importtime
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
#print(n)
return pow(n, 2)
deftest2(m):
(m.result())
t_pool = threadpoolexecutor(5) #
執行緒池中線程的數量
t_li =
for i in range(12):
t_pool.submit(test1, i).add_done_callback(test2)
#**函式
importtime
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
(n)
return pow(n, 2)
t_pool = threadpoolexecutor(5) #
執行緒池中線程的數量
t_pool.map(test1, range(6)) #
map()非同步
python 執行緒池 Python的執行緒池
usr bin env python coding utf 8 concurrent 用於執行緒池和程序池程式設計而且更加容易,在python3.2中才有。import sys from concurrent.futures import threadpoolexecutor,as complete...
python 執行緒池 python執行緒池原始碼解析
本篇主要講下threadpoolexecutor的實現。由於業務量不大,且一直使用框架進行程式設計,對執行緒的理解一直很模糊,基本處於不想阻塞程式執行,起乙個執行緒啟動任務的階段。總感覺自己好像會執行緒一樣,實則一直處於一種懵懂狀態,通過一段時間檢視一些別人寫的原始碼,終於有所悟,也記錄下自己的學習...
python執行緒池
import time threadpool為執行緒池模組 import threadpool deftest str print str time.sleep 2 if name main starttime time.time 建立執行緒池,最多建立的執行緒數為10 pool threadpoo...