如何中断 ExecutorService 的线程

Question

当使用Executors.newSingleThreadExecutor()返回的ExecutorService时，如何中断它？

Answer 1

为此，您需要 submit() 将任务发送给 ExecutorService，而不是调用 execute()。当您执行此操作时，将返回一个可用于操作计划任务的 Future。特别是，您可以调用 cancel(true) 在关联的 Future 上中断当前正在执行的任务（或者如果任务尚未开始运行则完全跳过执行） 。

顺便说一下， Executors.newSingleThreadExecutor() 实际上是一个ExecutorService。

Answer 2

中断执行程序的内部管理线程的另一种方法是调用 ExecutorService 上的 shutdownNow(..) 方法。但请注意，与 @erickson 的解决方案相反，这将导致整个 ThreadPoolExecutor 变得不适合进一步使用。

我发现这种方法在不再需要 ExecutorService 的情况下特别有用，并且不需要继续关注 Future 实例（一个典型的例子是 exit(..) 应用程序的方法）。

来自 ExecutorService#shutdownNow(..) javadocs 的相关信息：

尝试停止所有正在执行的任务，停止处理
等待任务，并返回正在等待的任务列表
执行。

除了尽力尝试停止处理之外，没有任何保证
积极执行任务。例如，典型的实现将
通过 Thread.interrupt 取消，因此任何无法响应的任务
中断可能永远不会终止。

Answer 3

一种正确的方法可能是为 ExecutorService 自定义/注入 ThreadFactory ，并从线程工厂中获取创建的线程的句柄，然后您可以安排一些任务来执行中断感兴趣的线程。

ThreadFactory 中覆盖方法 newThread 的演示代码部分：

ThreadFactory customThreadfactory new ThreadFactory() {

            public Thread newThread(Runnable runnable) {
                final Thread thread = new Thread(runnable);
                if (namePrefix != null) {
                    thread.setName(namePrefix + "-" + count.getAndIncrement());
                }
                if (daemon != null) {
                    thread.setDaemon(daemon);
                }
                if (priority != null) {
                    thread.setPriority(priority);
                }
                
                scheduledExecutorService.schedule(new Callable<String>() {
                    public String call() throws Exception {
                        System.out.println("Executed!");
                        thread.interrupt();
                        return "Called!";
                    }
                }, 5, TimeUnit.SECONDS);
                
                return thread;
            }

}

然后您可以使用下面的代码来构造您的 ExecutorService 实例：

ExecutorService executorService = Executors.newFixedThreadPool(3,
        customThreadfactory);

然后 5 秒后，中断信号将被发送到ExecutorService中的线程。