python 執行緒池

2022-04-02 04:44:40 字數 1645 閱讀 9429

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...