Java线程池拒绝策略与异常处理解析

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《Java线程池拒绝策略与异常处理详解》，这篇文章主要讲到等等知识，如果你对文章相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

线程池在高并发下需处理任务拒绝和异常。当无法接收新任务时，触发拒绝策略：AbortPolicy抛异常、CallerRunsPolicy由调用线程执行、DiscardPolicy丢弃新任务、DiscardOldestPolicy丢弃最老任务；可自定义策略记录日志或持久化。任务异常方面，Runnable未捕获异常会导致线程终止但不传播，可通过try-catch、使用Callable结合Future.get()获取异常、重写afterExecute方法或设置ThreadFactory的UncaughtExceptionHandler来捕获和处理异常，提升系统健壮性与可观测性。

线程池在高并发场景中广泛使用，但当任务提交速度超过处理能力或线程池已关闭时，就会触发拒绝策略。同时，任务执行过程中可能抛出异常，若不妥善处理，会导致任务“静默失败”。Java 提供了多种机制来应对这些问题。

线程池拒绝策略

当线程池无法接受新任务时（如队列已满且线程数达到最大值），会触发RejectedExecutionHandler。JDK 提供了四种内置策略：

• AbortPolicy：默认策略，抛出 RejectedExecutionException 异常。
• CallerRunsPolicy：由提交任务的线程直接执行该任务，减缓提交速度。
• DiscardPolicy：静默丢弃新任务，不抛异常。
• DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试提交当前任务。

可根据业务需求选择合适策略。例如，在对数据完整性要求高的系统中，应使用 AbortPolicy 及时暴露问题；在可容忍延迟的场景下，CallerRunsPolicy 能起到“背压”作用。

也可自定义拒绝策略，记录日志、报警或持久化任务用于后续恢复：

new RejectedExecutionHandler() {
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        System.err.println("任务被拒绝: " + r.toString());
        // 可将任务写入磁盘或消息队列
    }
}

线程池中的异常管理

普通 Runnable 任务中未捕获的异常会导致线程终止，但不会传播到主线程。ThreadPoolExecutor 在执行任务时会捕获 Throwable，若 Runnable 没有显式 try-catch，异常会被吞掉。

解决方法有以下几种：

• 在 Runnable 中使用 try-catch：最直接的方式，在 run 方法内处理异常。
• 使用 Callable 替代 Runnable：Callable 可抛出异常，通过 Future.get() 获取结果时会重新抛出 ExecutionException，原始异常作为其 cause。
• 重写 afterExecute 方法：继承 ThreadPoolExecutor，覆盖 afterExecute(Runnable, Throwable) 方法，在任务执行后检查异常：

protected void afterExecute(Runnable r, Throwable t) {
    super.afterExecute(r, t);
    if (t != null) {
        System.err.println("任务执行异常: " + t);
    } else if (r instanceof Future) {
        try {
            ((Future>) r).get();
        } catch (CancellationException ce) {
            t = ce;
        } catch (ExecutionException ee) {
            t = ee.getCause();
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
        } finally {
            if (t != null) {
                System.err.println("异步任务异常: " + t);
            }
        }
    }
}

设置未捕获异常处理器

Thread 支持设置 UncaughtExceptionHandler，但线程池创建的线程通常不会自动设置。可在创建线程工厂时指定：

ThreadFactory factory = r -> {
    Thread t = new Thread(r);
    t.setUncaughtExceptionHandler((thread, ex) ->
        System.err.println("线程异常: " + thread.getName() + ", 异常: " + ex)
    );
    return t;
};
ExecutorService exec = Executors.newFixedThreadPool(4, factory);

这样即使任务中未捕获异常，也能被统一处理。

基本上就这些。合理配置拒绝策略和异常捕获机制，能显著提升系统的健壮性和可观测性。

好了，本文到此结束，带大家了解了《Java线程池拒绝策略与异常处理解析》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多文章知识！