使用ExecutorService并发执行多线程仅完成部分任务，求排查及方案建议

嘿，我来帮你搞定这个线程池任务没执行完的问题！首先明确一点：你完全不需要急着换成ScheduledThreadPool——它是用来处理定时/周期性任务的，你的场景是一次性提交30个任务，FixedThreadPool本身就是合适的选择，问题出在任务执行的等待逻辑或者任务本身的异常处理上。

为什么会出现只执行部分任务的情况？ #

常见的原因有这几个：

• 主线程提前终止：如果你的主线程在提交完任务后，没等线程池里的任务全部执行完就退出了，JVM会直接终止所有后台线程，剩下的任务自然就没机会执行。你加了休眠，但休眠时间可能不够覆盖所有任务的执行时长，而且这种方式非常不可靠。
• 任务抛出未捕获异常：有些任务可能在执行中抛出了RuntimeException但没被捕获，虽然FixedThreadPool会自动替换异常的线程，但那个抛出异常的任务会直接终止，看起来就像“没执行”，但其实是执行失败了。
• 任务阻塞/死锁：如果任务之间有资源竞争或者互相等待的逻辑，可能会导致部分任务卡住，无法完成。

具体解决方案 #

1. 用正确的方式等待线程池完成所有任务 #

别再用Thread.sleep()了，改用线程池的shutdown() + awaitTermination()组合，这是等待所有任务执行完成的标准做法：

ExecutorService executor = Executors.newFixedThreadPool(10);

// 提交30个任务
for (int i = 0; i < 30; i++) {
    final int taskId = i;
    executor.submit(() -> {
        // 这里写你的任务逻辑
        System.out.println("正在执行任务: " + taskId);
        // 模拟任务耗时，根据实际情况调整
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("任务" + taskId + "被中断");
        }
    });
}

// 第一步：关闭线程池，不再接受新任务
executor.shutdown();

try {
    // 第二步：等待所有任务完成，设置一个合理的超时时间（比如30秒）
    if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
        // 如果超时，强制中断所有未完成的任务
        executor.shutdownNow();
        // 再等1秒确认关闭
        if (!executor.awaitTermination(1, TimeUnit.SECONDS)) {
            System.err.println("线程池无法正常关闭");
        }
    }
} catch (InterruptedException e) {
    // 如果当前主线程被中断，也强制关闭线程池
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

2. 排查任务是否有未捕获异常 #

给线程池设置未捕获异常处理器，或者在任务内部捕获所有异常，这样就能知道是不是任务执行失败了：

// 创建线程池时自定义线程工厂，添加异常处理器
ExecutorService executor = Executors.newFixedThreadPool(10, r -> {
    Thread thread = new Thread(r);
    thread.setUncaughtExceptionHandler((t, e) -> {
        System.err.println("任务执行异常，线程ID: " + t.getId() + "，异常信息: " + e.getMessage());
        e.printStackTrace();
    });
    return thread;
});

// 提交任务时，在任务内部捕获所有异常
executor.submit(() -> {
    try {
        // 你的任务逻辑
    } catch (Exception e) {
        System.err.println("任务执行失败: " + e.getMessage());
        // 这里可以添加日志记录等逻辑
    }
});

3. 检查任务是否有阻塞/死锁 #

如果任务涉及资源共享（比如锁、数据库连接等），检查是否有死锁的情况，或者任务是否因为等待某个资源而卡住。可以用JDK的jstack工具查看线程状态，排查阻塞的线程。

关于ScheduledThreadPool的疑问 #

如果你的需求只是一次性执行30个并行任务，完全不需要换成ScheduledThreadPool。它的核心能力是调度定时任务（比如延迟5秒执行、每隔1分钟执行一次），对于你的场景来说，FixedThreadPool已经足够，解决上面的问题就能让所有任务执行完成。

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