python 執行緒池

1、新模組

from concurrent.futures import

threadpoolexecutor
from concurrent.futures import processpoolexecutor

2、方法

"""

執行緒數量一般是cpu個數*5
submit(函式名, 引數)
map(函式名, 可迭代物件)
obj.shutdown() 相當於obj.close()和obj.join()
obj.result() 獲取返回值
and_done_callback(函式)，**函式
done() 檢視某個執行緒是否完成
"""

3、示例

import

time
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
print
(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())

import

time
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
#print(n)
return pow(n, 2)
deftest2(m):
print
(m.result())
t_pool = threadpoolexecutor(5) #
執行緒池中線程的數量
t_li =
for i in range(12):
t_pool.submit(test1, i).add_done_callback(test2) 
#**函式

import

time
from concurrent.futures import
threadpoolexecutor
deftest1(n):
time.sleep(0.5)
print
(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...