【线程池】ScheduledThreadPool异常处理

最新推荐文章于 2025-03-01 16:19:23 发布

章鱼

最新推荐文章于 2025-03-01 16:19:23 发布

阅读量1.2k

点赞数

分类专栏： # 并发编程

本文链接：https://blog.csdn.net/Code_shadow/article/details/107306902

版权

并发编程专栏收录该内容

15 篇文章

订阅专栏

探讨了ScheduledThreadPool在遇到异常任务时的处理机制，分析了一个因数据合规校验缺失导致任务挂起的问题案例，并提供了相应的解决方案。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

背景

某个任务类负责定时处理一些抽取数据的逻辑，通过定时线程池来实现。

问题

这天发现数据没有被处理，初步检查后定位到是因为放到线程池的这个任务并没有执行，而其他任务却可以正常地执行。

分析

梳理该任务的代码逻辑，其中因为在处理数据的过程中遗漏了对数据的合规校验，而正是因为这次残缺的数据而导致代码抛出异常。

通过查找资料和demo测试，发现ScheduledThreadPool这个定时线程池对抛出异常的任务会进行挂起，此后不会再进行调用。

解决

在任务中对任务进行合规校验

可对不可避免的异常进行捕获，避免异常被抛到任务外

测试

public class ScheduledThreadPoolTest {

    public static void main(String[] args) {

        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(3);

        scheduledExecutorService.scheduleAtFixedRate(() -> System.out.println("A"), 0, 2, TimeUnit.SECONDS);
        
        scheduledExecutorService.scheduleAtFixedRate(() -> {
            System.out.println("B");
            throw new RuntimeException();
        }, 0, 2, TimeUnit.SECONDS);
        
        scheduledExecutorService.scheduleAtFixedRate(() -> System.out.println("C"), 0, 2, TimeUnit.SECONDS);
    }
}