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,则应该执行清理操作并退出任务。

BlessAI
BlessAI

Bless 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、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

387

2023.07.18

堆和栈区别
堆和栈区别

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

571

2023.08.10

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

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

480

2023.08.10

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

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

60

2025.12.01

Java 桌面应用开发(JavaFX 实战)
Java 桌面应用开发(JavaFX 实战)

本专题系统讲解 Java 在桌面应用开发领域的实战应用,重点围绕 JavaFX 框架,涵盖界面布局、控件使用、事件处理、FXML、样式美化(CSS)、多线程与UI响应优化,以及桌面应用的打包与发布。通过完整示例项目,帮助学习者掌握 使用 Java 构建现代化、跨平台桌面应用程序的核心能力。

34

2026.01.14

php与html混编教程大全
php与html混编教程大全

本专题整合了php和html混编相关教程,阅读专题下面的文章了解更多详细内容。

14

2026.01.13

PHP 高性能
PHP 高性能

本专题整合了PHP高性能相关教程大全,阅读专题下面的文章了解更多详细内容。

33

2026.01.13

MySQL数据库报错常见问题及解决方法大全
MySQL数据库报错常见问题及解决方法大全

本专题整合了MySQL数据库报错常见问题及解决方法,阅读专题下面的文章了解更多详细内容。

18

2026.01.13

PHP 文件上传
PHP 文件上传

本专题整合了PHP实现文件上传相关教程,阅读专题下面的文章了解更多详细内容。

12

2026.01.13

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
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号