0

0

如何优雅地停止ExecutorService中的线程

DDD

DDD

发布时间:2025-08-13 19:50:01

|

720人浏览过

|

来源于php中文网

原创

如何优雅地停止executorservice中的线程

本文旨在解决在使用ExecutorService时,如何在超时或其他特定情况下停止正在运行的线程,同时避免完全关闭ExecutorService,以便后续任务仍然可以提交。我们将探讨使用shutdownNow()方法结合Thread.interrupted()标志的正确方式,以及如何在Runnable任务中优雅地处理中断请求。

在使用ExecutorService处理并发任务时,有时需要在特定条件下(例如超时)停止正在执行的任务。直接粗暴地终止线程是不推荐的,因为它可能导致资源泄漏或数据不一致。更优雅的方式是请求线程停止,并让线程自身处理停止逻辑。

使用 shutdownNow() 请求停止线程

ExecutorService 提供了 shutdownNow() 方法,该方法尝试停止所有正在执行的任务,暂停处理正在等待的任务,并返回等待执行的任务列表。重要的是,shutdownNow() 并不会立即杀死线程,而是设置每个线程的 interrupted 标志。

ExecutorService executor = Executors.newFixedThreadPool(10);
List> objectGroup = Lists.partition(objectList, 5);
for (List eachGroup : objectGroup ) {
    CountDownLatch latch = new CountDownLatch(eachGroup.size());
    for (Object obj: eachGroup) {
        executor.submit(() -> {
            try {
                doTask(obj);
            } catch (InterruptedException e) {
                // 处理中断异常,例如清理资源
                System.out.println("Task interrupted!");
            } finally {
                latch.countDown();
            }
        });
    }

    try {
        if (!latch.await(15, TimeUnit.MINUTES)) {
            // 超时,请求停止所有线程
            List droppedTasks = executor.shutdownNow();
            System.out.println("Timeout!  Tasks interrupted: " + droppedTasks.size());
        }
    }
    catch (InterruptedException e) {
        System.out.println("Interrupted while waiting for latch!");
        executor.shutdownNow();
    }

}

// 不要忘记在所有任务完成后关闭 ExecutorService
executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        System.err.println("Executor did not terminate in 60 seconds");
        executor.shutdownNow();
    }
} catch (InterruptedException ex) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

在 Runnable 任务中检查中断状态

为了使线程能够响应中断请求,需要在 Runnable 任务中定期检查 Thread.interrupted() 标志。如果该标志为 true,则应该执行清理操作并退出任务。

DreamGen
DreamGen

一个AI驱动的角色扮演和故事写作的平台

下载
public void doTask(Object obj) throws InterruptedException {
    while (!Thread.interrupted()) {
        // 执行任务的一部分
        // ...

        // 模拟耗时操作
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            // 重新设置中断标志,以便在方法栈的更高层也能感知到中断
            Thread.currentThread().interrupt();
            throw e; // 抛出 InterruptedException
        }
    }
    // 执行清理操作,例如释放资源
    System.out.println("Task is stopping gracefully.");
}

注意事项:

  • Thread.interrupted() 方法会清除当前线程的中断状态。如果需要在方法栈的更高层继续响应中断,需要在捕获 InterruptedException 后重新设置中断标志 Thread.currentThread().interrupt()。
  • executor.shutdownNow() 会返回一个List,其中包含尚未开始执行的任务。你可以根据需要处理这些被丢弃的任务。
  • 在所有任务完成后,务必调用 executor.shutdown() 来关闭 ExecutorService,并使用 awaitTermination() 方法等待所有线程完成。如果超时,可以再次调用 executor.shutdownNow()。
  • shutdownNow() 之后不能再提交新的任务,如果需要继续提交任务,则不应该调用此方法。

总结

通过结合使用 shutdownNow() 方法和在 Runnable 任务中检查 Thread.interrupted() 标志,可以实现优雅地停止 ExecutorService 中线程的目的。 这种方法避免了强制终止线程可能带来的问题,并允许线程自身负责清理资源和退出。 记住,在处理并发编程时,良好的错误处理和资源管理至关重要。

相关专题

更多
堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

371

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

563

2023.08.10

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

472

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

54

2025.12.01

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

65

2025.12.31

php网站源码教程大全
php网站源码教程大全

本专题整合了php网站源码相关教程,阅读专题下面的文章了解更多详细内容。

45

2025.12.31

视频文件格式
视频文件格式

本专题整合了视频文件格式相关内容,阅读专题下面的文章了解更多详细内容。

40

2025.12.31

不受国内限制的浏览器大全
不受国内限制的浏览器大全

想找真正自由、无限制的上网体验?本合集精选2025年最开放、隐私强、访问无阻的浏览器App,涵盖Tor、Brave、Via、X浏览器、Mullvad等高自由度工具。支持自定义搜索引擎、广告拦截、隐身模式及全球网站无障碍访问,部分更具备防追踪、去谷歌化、双内核切换等高级功能。无论日常浏览、隐私保护还是突破地域限制,总有一款适合你!

41

2025.12.31

出现404解决方法大全
出现404解决方法大全

本专题整合了404错误解决方法大全,阅读专题下面的文章了解更多详细内容。

232

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号