我的代碼利用 ThreadPoolExecutor 來處理多個任務(wù)。主要要求之一是它無限期地執(zhí)行。這是我當(dāng)前的實現(xiàn)：def process_something(): with ThreadPoolExecutor(max_workers=MAX_WORKERS1) as executor1: with ThreadPoolExecutor(max_workers=MAX_WORKERS2) as executor2: while True: func1_returns = executor1.map(func1, arg1) func2_returns = executor2.map(func2, arg2) # code for processing func returns time.sleep(1)有沒有更好的方法來實現(xiàn)這個？由于執(zhí)行器駐留在無限循環(huán)中，這是否可能導(dǎo)致內(nèi)存泄漏？
1 回答
翻閱古今
TA貢獻(xiàn)1780條經(jīng)驗 獲得超5個贊
線程池已經(jīng)有多個線程可以使用。您不需要創(chuàng)建多個池。
def process_something():
with ThreadPoolExecutor(max_workers=MAX_WORKERS1) as executor1:
while True:
func1_returns = executor1.submit(func1, arg1)
func2_returns = executor1.submit(func2, arg2)
# code for processing func returns
time.sleep(1)
線程池中不應(yīng)該有任何內(nèi)存泄漏。當(dāng)語句完成時，線程將被垃圾收集with。
添加回答
舉報
0/150
提交
取消