Java线程池是并发编程中常用的组件，通过复用线程减少线程创建销毁的开销，提升系统性能。但在实际使用中，线程池中的工作线程可能会出现异常退出的情况，影响任务的正常执行。
线程池线程异常退出的常见场景
1. 任务执行抛出未捕获异常
当线程池执行任务时，如果任务内部抛出未捕获的运行时异常，工作线程会直接终止。线程池的runWorker方法中，任务执行的逻辑被包裹在try代码块中，一旦抛出异常，线程就会退出循环，最终被回收。
以下是一段模拟任务抛出未捕获异常的示例代码：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExceptionDemo {
public static void main(String[] args) {
// 创建核心线程数为1，最大线程数为2，队列长度为10的线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(
1,
2,
60L,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(10)
);
// 提交一个会抛出运行时异常的任务
executor.execute(() -> {
System.out.println("任务开始执行");
// 抛出未捕获的算术异常
int result = 1 / 0;
});
// 再提交一个正常任务，观察线程池是否会创建新线程
executor.execute(() -> {
System.out.println("第二个任务执行");
});
executor.shutdown();
}
}
上述代码中，第一个任务执行时会抛出除零异常，工作线程会异常退出，线程池会重新创建一个新线程来执行第二个任务。
2. 线程被外部中断
如果线程池中的线程被调用了interrupt方法，且任务内部没有正确处理中断信号，线程可能会在中断后退出。比如任务中调用了会响应中断的阻塞方法，抛出InterruptedException后如果没有重新设置中断状态，线程就会终止。
以下是线程被中断导致退出的示例代码：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadInterruptDemo {
public static void main(String[] args) throws InterruptedException {
ThreadPoolExecutor executor = new ThreadPoolExecutor(
1,
1,
60L,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(10)
);
// 提交一个阻塞任务
executor.execute(() -> {
try {
Thread.sleep(5000);
System.out.println("任务执行完成");
} catch (InterruptedException e) {
// 捕获中断异常后没有处理，线程会退出
System.out.println("任务被中断");
}
});
// 等待1秒后中断线程池中的线程
Thread.sleep(1000);
executor.shutdownNow();
}
}
3. 线程池配置不合理导致线程回收
当线程池的核心线程数小于最大线程数，且非核心线程空闲时间超过keepAliveTime时，非核心线程会被回收。如果任务量波动大，频繁创建回收非核心线程，可能会被误认为是异常退出。
以下是非核心线程被回收的示例：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadRecycleDemo {
public static void main(String[] args) throws InterruptedException {
// 核心线程1，最大线程2，空闲存活时间1秒
ThreadPoolExecutor executor = new ThreadPoolExecutor(
1,
2,
1L,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(10)
);
// 提交两个任务，创建两个线程
executor.execute(() -> {
System.out.println("第一个任务执行");
});
executor.execute(() -> {
System.out.println("第二个任务执行");
});
// 等待2秒，非核心线程会被回收
Thread.sleep(2000);
System.out.println("当前线程池线程数：" + executor.getPoolSize());
}
}
如何避免线程异常退出
- 对提交到线程池的任务做好异常捕获，在任务内部处理所有可能的异常，避免异常抛出到线程池的调度逻辑中。
- 正确处理线程中断信号，在捕获
InterruptedException后，调用Thread.currentThread().interrupt()重新设置中断状态，让上层逻辑可以感知中断。 - 合理配置线程池参数，根据业务场景设置合适的核心线程数、最大线程数和空闲存活时间，避免不必要的线程回收。
- 如果需要核心线程也能被回收，可以调用
allowCoreThreadTimeOut(true)方法，明确线程回收的规则。
线程异常退出的排查方法
当发现线程池线程异常退出时，可以通过以下方式排查：
- 查看任务的执行日志，确认是否有未捕获的异常抛出。
- 通过线程池的监控参数，比如
getActiveCount、getTaskCount等，观察线程池的运行状态变化。 - 如果需要追踪线程退出的原因，可以自定义线程工厂，给线程设置未捕获异常处理器，捕获线程退出的异常信息。
以下是自定义线程工厂设置异常处理器示例：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class CustomThreadFactoryDemo {
public static void main(String[] args) {
ThreadFactory threadFactory = r -> {
Thread thread = new Thread(r);
// 设置未捕获异常处理器
thread.setUncaughtExceptionHandler((t, e) -> {
System.out.println("线程" + t.getName() + "异常退出，原因：" + e.getMessage());
});
return thread;
};
ThreadPoolExecutor executor = new ThreadPoolExecutor(
1,
1,
60L,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(10),
threadFactory
);
executor.execute(() -> {
int result = 1 / 0;
});
executor.shutdown();
}
}