已解决java.util.concurrent.CancellationException异常的正确解决方法,亲测有效!!!
文章目录
问题分析
报错原因
解决思路
解决方法
总结
在Java并发编程中,Future和FutureTask是处理异步计算结果的重要工具类。然而,在使用这些工具进行并发编程时,我们可能会遇到java.util.concurrent.CancellationException异常。本异常表明因为任务被取消,导致无法检索到产生值的任务(如FutureTask)的结果。此文将深入分析CancellationException异常的原因,并提供详细的解决方案。
问题分析
CancellationException异常通常出现在尝试获取一个已经被取消的任务的结果时。在Java的并发框架中,如果一个任务正在执行或等待执行,我们可以通过调用cancel(boolean mayInterruptIfRunning)方法来取消这个任务。如果取消成功,任何后续对该任务的get()调用都将抛出CancellationException。
出现问题的场景
- 在多线程环境下,一个长时间运行的任务被显式取消。
- 调用
Future.get()方法获取异步计算的结果时,如果计算任务已经被取消。 - 利用
ExecutorService执行一组任务,并在所有任务完成之前调用shutdownNow()方法,可能会引发此异常。
报错原因
导致CancellationException的具体原因主要包括:
- 任务被取消:当任务通过
Future.cancel(true)方法被取消后,仍然尝试通过Future.get()方法获取结果。 - 线程池关闭:当线程池通过
shutdownNow()方法关闭,正在等待的或正在执行的任务将被尝试中断,进而可能导致任务取消。
解决思路
面对CancellationException异常,解决方案可从以下几个方向考虑:
- 合理处理取消操作:正确管理任务的取消操作,只在必要时取消任务。
- 优雅关闭线程池:使用
shutdown()和awaitTermination()组合替代shutdownNow(),以更优雅地关闭线程池。 - 异常捕获与处理:妥善捕获和处理
CancellationException,避免程序异常终止。
解决方法
- 合理处理取消操作:谨慎取消任务,确保只在确实需要取消任务以释放资源或因为用户请求停止操作时,才取消任务。
Future<?> future = executor.submit(longRunningTask);
// 基于某些条件判断是否需要取消任务
if (shouldCancel) {future.cancel(true);
}
- 优雅关闭线程池:平滑关闭线程池,首先调用
shutdown()方法停止接收新任务,然后调用awaitTermination()等待已有任务完成。
ExecutorService executor = Executors.newFixedThreadPool(10);
// 添加任务到executor
executor.shutdown(); // 停止接收新任务
try {if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {executor.shutdownNow(); // 取消当前执行的任务}
} catch (InterruptedException ie) {executor.shutdownNow();Thread.currentThread().interrupt(); // 保留中断状态
}
- 异常捕获与处理:妥善处理
CancellationException,在调用Future.get()时,准备好捕获并妥善处理CancellationException。
try {Object result = future.get();
} catch (CancellationException ce) {// 处理任务被取消的情况System.out.println("任务被取消");
} catch (InterruptedException ie) {Thread.currentThread().interrupt(); // 保留中断状态
} catch (ExecutionException ee) {// 处理任务执行过程中的异常
}
总结
通过上述步骤的实施,可以有效地解决由于任务被取消而引发的java.util.concurrent.CancellationException异常问题。在并发编程实践中,合理的任务管理和异常处理策略是保证程序稳定运行的关键。希望本文的内容对您解决相关问题提供了清晰的指导和帮助。
以上是此问题报错原因的解决方法,欢迎评论区留言讨论是否能解决,如果本文对你有帮助 欢迎 关注 、点赞 、收藏 、评论, 博主才有动力持续记录遇到的问题!!!
博主v:XiaoMing_Java
📫作者简介:嗨,大家好,我是 小明java问道之路,互联网大厂后端研发专家,2022博客之星TOP3 / 博客专家 / CSDN后端内容合伙人、InfoQ(极客时间)签约作者、阿里云签约博主、全网5万粉丝博主。
🍅 文末获取联系 🍅 👇🏻 精彩专栏推荐订阅收藏 👇🏻
专栏系列(点击解锁)
学习路线(点击解锁)
知识定位
🔥Redis从入门到精通与实战🔥
Redis从入门到精通与实战
围绕原理源码讲解Redis面试知识点与实战
🔥MySQL从入门到精通🔥
MySQL从入门到精通
全面讲解MySQL知识与企业级MySQL实战 🔥计算机底层原理🔥
深入理解计算机系统CSAPP
以深入理解计算机系统为基石,构件计算机体系和计算机思维
Linux内核源码解析
围绕Linux内核讲解计算机底层原理与并发
🔥数据结构与企业题库精讲🔥
数据结构与企业题库精讲
结合工作经验深入浅出,适合各层次,笔试面试算法题精讲
🔥互联网架构分析与实战🔥
企业系统架构分析实践与落地
行业最前沿视角,专注于技术架构升级路线、架构实践
互联网企业防资损实践
互联网金融公司的防资损方法论、代码与实践
🔥Java全栈白宝书🔥
精通Java8与函数式编程
本专栏以实战为基础,逐步深入Java8以及未来的编程模式
深入理解JVM
详细介绍内存区域、字节码、方法底层,类加载和GC等知识
深入理解高并发编程
深入Liunx内核、汇编、C++全方位理解并发编程
Spring源码分析
Spring核心七IOC/AOP等源码分析
MyBatis源码分析
MyBatis核心源码分析
Java核心技术
只讲Java核心技术