使用 ThreadPoolExecutor 实现无限循环的最佳方法是什么？

Question

我的代码利用 ThreadPoolExecutor 来处理多个任务。主要要求之一是它无限期地执行。这是我当前的实现：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)有没有更好的方法来实现这个？由于执行器驻留在无限循环中，这是否可能导致内存泄漏？

Answer 1

线程池已经有多个线程可以使用。您不需要创建多个池。

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。