使用 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。