如何实现已完成线程被待启动线程动态替换的Java线程调度

你的核心需求是维持固定数量的线程持续运行，某个线程完成任务后立刻启动新线程替换它，而不是等整组线程全部完成再启动下一批。原代码的问题在于每次循环都会无条件创建10个新线程，不管之前的线程是否结束，最终会导致系统中线程数量爆炸，完全不符合需求。

最优实现：使用ThreadPoolExecutor #

Java的线程池框架可以自动帮你管理线程的创建、复用和销毁，完美匹配你的需求。你可以固定初始线程数，后续还能动态调整数量（比如从10改成15）。

代码示例

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadReplacementDemo {
    public static void main(String[] args) {
        // 初始化线程池：核心线程数10，最大线程数10，空闲核心线程不会被回收
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                10,
                10,
                0L,
                TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<>()
        );

        // 后续如果需要调整到15个线程，直接修改参数即可
        // executor.setCorePoolSize(15);
        // executor.setMaximumPoolSize(15);

        // 持续提交任务，线程池会自动维护运行的线程数量
        while (true) {
            executor.submit(() -> {
                System.out.println("hi from thread: " + Thread.currentThread().getName());
                // 模拟任务耗时（替换成你的实际任务逻辑）
                try {
                    Thread.sleep((long) (Math.random() * 3000)); // 随机0-3秒耗时
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            });

            // 可选：控制任务提交速度，避免无界队列内存溢出
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }

        // 当不需要运行时，记得关闭线程池
        // executor.shutdown();
    }
}

关键逻辑说明 #

1. 线程池自动复用线程：当某个线程完成任务后，不会立刻销毁，而是会从任务队列中取出下一个任务执行，相当于自动替换完成的线程。
2. 动态调整线程数量：通过setCorePoolSize和setMaximumPoolSize方法，可以随时调整同时运行的线程数（比如从10改成15）。
3. 避免线程爆炸：线程池会严格控制最大线程数，不会像原代码那样无限制创建新线程，防止系统资源耗尽。

原代码的问题复盘 #

你的原代码在while(true)循环中每次都创建10个新线程，完全不考虑之前的线程是否已经结束。运行一段时间后，系统中会存在大量同时运行的线程，不仅会消耗大量内存和CPU资源，也完全无法实现“完成一个补一个”的需求。

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