我的代碼利用 ThreadPoolExecutor 來處理多個任務。主要要求之一是它無限期地執(zhí)行。這是我當前的實現：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)有沒有更好的方法來實現這個？由于執(zhí)行器駐留在無限循環(huán)中，這是否可能導致內存泄漏？
1 回答
翻閱古今
TA貢獻1780條經驗 獲得超5個贊
線程池已經有多個線程可以使用。您不需要創(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)
線程池中不應該有任何內存泄漏。當語句完成時，線程將被垃圾收集with。
添加回答
舉報
0/150
提交
取消