如何实现固定10线程并发且单线程结束后立即启动新线程？

要实现最多同时运行10个线程、单个线程执行完成后立即启动新线程的需求，本质是维持固定大小的工作线程池，无需等待全部线程执行结束再批量启动新线程，以下是两种可直接落地的实现方案：

方案1：使用标准库线程池（最简洁） #

Python 自带的 concurrent.futures.ThreadPoolExecutor 天生支持固定并发数控制，只需要指定 max_workers=10，提交所有待执行任务后，它会自动维持最多10个线程同时运行，单个线程执行完当前任务会立即取下一个待执行任务运行，完全匹配需求。
示例代码如下：

from concurrent.futures import ThreadPoolExecutor

# 自定义线程执行的业务逻辑
def task(task_id):
    print(f"任务{task_id}开始执行")
    # 此处替换为实际业务代码
    import time
    time.sleep(2)
    print(f"任务{task_id}执行完成")

if __name__ == "__main__":
    # 指定最大并发线程数为10
    with ThreadPoolExecutor(max_workers=10) as executor:
        # 假设总共有100个待执行任务，可根据实际需求调整
        total_task_count = 100
        # 批量提交所有任务，线程池自动调度，无需手动管理启停
        for task_id in range(total_task_count):
            executor.submit(task, task_id)

该方案无需手动处理线程的等待、启动逻辑，所有调度逻辑由标准库内部实现，稳定性高。

方案2：手动实现动态补线程逻辑 #

如果你需要自定义线程的创建规则，可通过「活跃线程存活检测+动态补全」的逻辑手动实现：

• 维护列表存储当前运行中的线程
• 循环清理已结束的线程，只要活跃线程数不足10就启动新线程
  示例代码如下：

import threading
import time

def task(task_id):
    print(f"任务{task_id}开始执行")
    time.sleep(2)
    print(f"任务{task_id}执行完成")

if __name__ == "__main__":
    max_concurrent = 10
    total_task_count = 100
    current_task_id = 0
    running_threads = []

    while current_task_id < total_task_count:
        # 过滤掉已经执行完成的线程
        running_threads = [t for t in running_threads if t.is_alive()]
        # 活跃线程不足10个时补新线程
        while len(running_threads) < max_concurrent and current_task_id < total_task_count:
            new_thread = threading.Thread(target=task, args=(current_task_id,))
            new_thread.start()
            running_threads.append(new_thread)
            current_task_id += 1
        # 避免空转占用CPU，每次检测间隔100ms
        time.sleep(0.1)
    
    # 所有任务提交完成后，等待剩余活跃线程执行结束
    for t in running_threads:
        t.join()

该方式可灵活自定义线程的属性，比如设置daemon状态、线程名称、异常捕获规则等。

注意事项 #

• 若执行的是IO密集型任务，使用线程池方案即可；若为CPU密集型任务，更推荐使用multiprocessing.Pool进程池，避免GIL带来的性能限制
• 不要在业务执行函数内调用join()，会导致线程阻塞无法正常并发
• 手动实现时必须添加短时间的sleep，避免循环空转占满CPU资源

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