【Java】已解决java.util.concurrent.RejectedExecutionException异常

简介: 【Java】已解决java.util.concurrent.RejectedExecutionException异常

已解决java.util.concurrent.RejectedExecutionException异常

一、问题背景

java.util.concurrent.RejectedExecutionException是Java并发编程中常见的一个异常,它通常发生在使用ExecutorService(如ThreadPoolExecutor)执行异步任务时,当任务提交到线程池但线程池无法处理新任务(比如,因为已经关闭了或者达到了其最大容量)时,就会抛出此异常。


在Web应用、后台服务或其他需要处理大量并发请求的系统中,经常可以看到此类异常的出现。下面,我们将探讨如何解决这一问题。

二、可能出错的原因

  • 线程池已满且RejectedExecutionHandler的默认策略是抛出异常。
  • 线程池已关闭,无法接受新任务。
  • 提交的任务数量超过了线程池的最大处理能力。

三、错误代码示例

假设我们有一个固定大小的线程池,但没有正确处理拒绝策略:

import java.util.concurrent.*;  
  
public class ThreadPoolExample {  
    public static void main(String[] args) {  
        ExecutorService executor = Executors.newFixedThreadPool(10); // 创建一个固定大小为10的线程池  
  
        // 假设我们提交了大量的任务  
        for (int i = 0; i < Integer.MAX_VALUE; i++) {  
            executor.execute(() -> {  
                // 模拟一个长时间运行的任务  
                try {  
                    Thread.sleep(1000);  
                } catch (InterruptedException e) {  
                    e.printStackTrace();  
                }  
            });  
        }  
  
        // 这里并没有关闭线程池  
    }  
}


在这个例子中,因为循环是无限的,线程池很快就会饱和,并且由于没有设置自定义的拒绝策略,当线程池无法接受新任务时,就会抛出RejectedExecutionException。

四、正确代码示例

为了解决这个问题,我们可以采取以下措施:

  1. 合理地设置线程池的大小。
  2. 使用合适的队列来存储待处理的任务。
  3. 实现一个自定义的拒绝策略。
import java.util.concurrent.*;  
  
public class ThreadPoolExampleWithRejectionHandler {  
    public static void main(String[] args) {  
        // 创建一个固定大小为10的线程池,并使用一个无界队列(这里仅作为示例,通常不推荐使用无界队列)  
        ExecutorService executor = new ThreadPoolExecutor(  
                10, // 核心线程数  
                10, // 最大线程数  
                0L, TimeUnit.MILLISECONDS, // 空闲线程等待新任务的最长时间  
                new LinkedBlockingQueue<>(), // 使用无界队列  
                Executors.defaultThreadFactory(),  
                new ThreadPoolExecutor.CallerRunsPolicy() // 使用调用者运行策略作为拒绝策略  
        );  
  
        // 提交任务(注意这里应有一个合理的控制,防止无限制地提交任务)  
        // ...  
  
        // 当不再需要提交新任务时,优雅地关闭线程池  
        executor.shutdown(); // 开始关闭过程,不再接受新任务  
        try {  
            // 等待所有任务完成,或者超时等待  
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {  
                // 超时了,可以取消未完成的任务  
                executor.shutdownNow(); // 尝试停止所有正在执行的任务,停止处理正在等待的任务,并返回等待执行的任务列表  
            }  
        } catch (InterruptedException ie) {  
            // 如果当前线程在等待过程中被中断,则重新中断线程池中的线程  
            executor.shutdownNow();  
            // 保存中断状态  
            Thread.currentThread().interrupt();  
        }  
    }  
}


在这个例子中,我们使用了ThreadPoolExecutor的构造函数来创建一个线程池,并指定了一个CallerRunsPolicy的拒绝策略。当线程池不能接受新任务时,它会尝试在调用execute的线程中运行该任务。

五、注意事项

  • 在设计线程池时,要充分考虑系统的并发需求和资源限制,合理设置线程池的大小和队列容量。
  • 对于需要长时间运行的任务,建议使用单独的线程或线程池来处理,避免阻塞核心线程池。
  • 在使用线程池时,要注意优雅地关闭线程池,避免资源泄露。
  • 在编写并发代码时,要特别注意线程安全问题,避免数据竞争和不一致的状态。
  • 合理地使用拒绝策略,根据业务需求选择合适的策略来处理无法执行的任务。

目录
相关文章
|
3月前
|
Java 开发者 UED
【实战宝典】Java异常处理大师级教程:throws关键字,让异常声明成为你的专属标签!
【实战宝典】Java异常处理大师级教程:throws关键字,让异常声明成为你的专属标签!
57 3
|
7天前
|
Java
如何在 Java 中处理“Broken Pipe”异常
在Java中处理“Broken Pipe”异常,通常发生在网络通信中,如Socket编程时。该异常表示写入操作的另一端已关闭连接。解决方法包括:检查网络连接、设置超时、使用try-catch捕获异常并进行重试或关闭资源。
|
9天前
|
存储 安全 Java
如何避免 Java 中的“ArrayStoreException”异常
在Java中,ArrayStoreException异常通常发生在尝试将不兼容的对象存储到泛型数组中时。为了避免这种异常,确保在操作数组时遵循以下几点:1. 使用泛型确保类型安全;2. 避免生类型(raw types)的使用;3. 在添加元素前进行类型检查。通过这些方法,可以有效防止 ArrayStoreException 的发生。
|
10天前
|
人工智能 Oracle Java
解决 Java 打印日志吞异常堆栈的问题
前几天有同学找我查一个空指针问题,Java 打印日志时,异常堆栈信息被吞了,导致定位不到出问题的地方。
24 2
|
14天前
|
Java 索引
如何避免在 Java 中引发`StringIndexOutOfBoundsException`异常
在Java中,处理字符串时若访问了不存在的索引,会抛出`StringIndexOutOfBoundsException`异常。为避免此异常,应确保索引值在有效范围内,例如使用`length()`方法检查字符串长度,并确保索引值不小于0且不大于字符串长度减1。
|
16天前
|
安全 Java 数据安全/隐私保护
如何配置 Java 安全管理器来避免访问控制异常
配置Java安全管理器以防止访问控制异常,需在启动JVM时通过 `-Djava.security.manager` 参数启用,并设置安全策略文件,定义权限规则,限制代码执行操作,确保应用安全。
|
22天前
|
Java
让星星⭐月亮告诉你,Java异常分类[Throwable(Error/Exception(RuntimeException/其他异常)) 检查时异常 非检查时异常]
本文深入解析了Java异常处理机制,重点介绍了`Throwable`类及其子类`Error`和`Exception`,并通过实例代码、流程图和表格详细解释了异常的分类、区别及处理方法,帮助读者掌握异常处理的关键技巧,提升程序的稳定性和健壮性。
40 1
|
27天前
|
Java 程序员
关于java异常
关于java异常
20 5
|
2月前
|
Java 编译器 数据库连接
Java——异常
在 Java 中,程序执行过程中的不正常行为被称为异常。异常分为 Error 和 Exception。Error 表示系统级错误,而 Exception 则封装程序可能出现的问题。异常包括编译时异常和运行时异常(如数组越界)。异常可用于查找 bug 信息和作为方法内部的特殊返回值。处理异常的方式有默认处理和捕获异常,后者通过 try-catch 结构实现。此外,还可以自定义异常类来更灵活地处理特定情况。
34 9
Java——异常
|
27天前
|
Java 程序员 编译器
Java中的异常类型
Java中的异常类型
21 3