如何使用ThreadPoolExecutor在满足条件时持续创建新线程直至达成目标？

你需要在result小于target时持续创建新线程，当前代码存在核心问题：主线程的while循环会短时间内向线程池提交大量任务塞进队列，而非按需在任务完成后提交新任务，同时还可能因GIL缓存机制导致主线程无法及时读取result的更新值。

以下是修正后的实现方案，既能保证线程池高效利用，又能精准控制任务提交时机：

修正后的代码 #

import concurrent.futures
import threading
import time
import uuid


lock = threading.Lock()
target = 20
result = 0


def main(uid: str) -> bool:
    global result
    print(f'Start - {uid}')
    time.sleep(2.0)
    # 使用with语句自动管理锁，避免手动释放遗漏
    with lock:
        result += 1
    print(f'Stop - {uid}')
    return True


if __name__ == '__main__':
    with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
        # 初始化线程池，先填满最大工作线程数的任务
        active_futures = {executor.submit(main, str(uuid.uuid4())) for _ in range(min(target, 2))}
        
        while result < target:
            # 等待任意一个任务完成
            done_futures, active_futures = concurrent.futures.wait(
                active_futures, 
                return_when=concurrent.futures.FIRST_COMPLETED
            )
            # 处理完成的任务（可按需获取返回值）
            for future in done_futures:
                future.result()
            # 检查是否还需要提交新任务
            if result < target:
                new_future = executor.submit(main, str(uuid.uuid4()))
                active_futures.add(new_future)

代码说明 #

1. 线程安全的变量更新：用with lock:替代手动acquire/release，确保锁的正确释放，避免死锁风险。
2. 动态任务提交：先提交与线程池最大容量匹配的初始任务，之后每次等待一个任务完成后，检查result是否仍小于target，若是则提交新任务，保证线程池始终满负载运行，不会一次性堆积大量任务。
3. 避免GIL缓存问题：通过wait跟踪任务完成状态，主线程的循环仅在任务完成后继续，自然能读取到最新的result值。

内容的提问来源于stack exchange，提问作者Petr Nalich