如何立即停止使用 ExecutorService 启动的任务？

Question

我尝试了许多不同的方法来立即停止使用 ExecutorService 启动的任务，但没有成功。

Future<Void> future = executorService.submit(new Callable<Void>(
    public Void call () {
        ... do many other things here..
        if(Thread.currentThread.isInterrupted()) {
            return null;
        }
        ... do many other things here..
        if(Thread.currentThread.isInterrupted()) {
            return null;
        }
    }
));

if(flag) { // may be true and directly cancel the task
    future.cancel(true);
}

有时我需要在任务启动后立即取消任务，您可能会好奇为什么我要这样做，您可能会想象这样一个场景：用户不小心点击了“下载”按钮来启动“下载任务”，然后他立即想要取消该操作，因为这只是意外点击。

问题是，调用 future.cancel(true) 后，任务没有停止，Thread.currentThread.isInterrupted() 仍然返回 false我无法知道任务是从 call() 方法内部停止的。

我正在考虑在调用 future.cancel(true) 并在 call() 方法中不断检查该标志后设置一个类似 cancelled=true 的标志，我认为这是一个 hack，代码可能非常很难看，因为用户可以同时启动许多任务。

有没有更优雅的方式来实现我想要的？

编辑：

这真的让我抓狂。我现在已经在这个问题上花了将近一天的时间了。我将尝试对我面临的问题进行更多解释。

我执行以下操作来启动 5 个任务，每个任务将启动 5 个线程来下载文件。然后我立即停止所有 5 项任务。对于下面的所有方法调用，我启动一个线程（ExecutorService.submit（task））以使其异步，正如您可以从方法的后缀中看出的那样。

int t1 = startTaskAysnc(task1);
int t2 = startTaskAysnc(task2);
int t3 = startTaskAysnc(task3);
int t4 = startTaskAysnc(task4);
int t5 = startTaskAysnc(task5);

int stopTaskAysnc(t1);
int stopTaskAysnc(t2);
int stopTaskAysnc(t3);
int stopTaskAysnc(t4);
int stopTaskAysnc(t5);

在 startTaskAysnc() 中，我只是发起一个到远程服务器的套接字连接来获取文件的大小（这肯定需要一些时间），在成功获取文件大小后，我将启动 5 个线程下载文件的不同部分。如下所示（代码经过简化，使其更易于理解）：

public void startTaskAsync(DownloadTask task) { 
    Future<Void> future = executorService.submit(new Callable<Void>(
        public Void call () {
            // this is a synchronous call
            int fileSize = getFileSize();
            System.out.println(Thread.currentThread.isInterrupted());
            ....
            Future<Void> futures = new Future<Void>[5];
            for (int i = 0; i < futures.length; ++i) {
                futures[i] = executorService.submit(new Callable<Void>(){...});
            }

            for (int i = 0; i < futures.length; ++i) {
                futures[i].get(); // wait for it to complete
            }            
        }
    ));
    synchronized (mTaskMap) {
        mTaskMap.put(task.getId(), future);
    }
}

public void stopTaskAysnc(int taskId) {
    executorService.execute(new Runnable(){
        Future<Void> future = mTaskMap.get(taskId);
        future.cancel(true);
    });
}

我注意到一种奇怪的行为，在我为所有 5 个任务调用 stopTaskAsync() 后，总会有至少一个任务停止（即Thread.currentThread.isInterrupted()返回true），其他4个任务继续运行。

我已经通过设置 UncaughtExceptionHandler 尝试了您的建议，但没有任何结果。

编辑：

问题已在此链接中解决：无法停止使用 ExecutorService 启动的任务

Answer 1

好吧，javadoc< Future.cancel(boolean) 的 /a> 表示：

如果任务已经开始，则 mayInterruptIfRunning
参数决定执行此任务的线程是否应该
试图停止任务时被中断。

因此可以肯定的是，执行任务的线程被中断了。可能发生的情况之一是

...在这里做很多其他事情..

意外地清除了Thread的interrupted状态而不执行所需的操作
处理。如果您在 Thread.interrupt() 中放置断点，您可能会抓住罪犯。

我能想到的另一个选择是任务在捕获中断之前终止，因为它已完成或抛出了一些未捕获的异常。调用 Future.get() 来确定。无论如何，正如 asdasd 提到的，设置 UncaughtExceptionHandler 是一个很好的做法。

Answer 2

您正在做的事情非常危险：您正在使用线程池来执行任务（我将其称为下载器），并使用相同的线程池来执行

• 等待下载器完成的任务（我将其称为控制器） ）
• 或要求控制器停止

这意味着，如果在控制器启动后达到核心线程数，下载器将被放入线程池的队列中，并且控制器线程将永远不会完成。同样，如果执行取消任务时达到了核心线程数，则该取消任务将被放入队列中，直到其他任务完成后才会执行。

您可能应该为下载程序使用一个线程池，为控制器使用另一个线程池，并使用当前线程来取消控制器。

Answer 3

我想您会在这里找到解决方案。要点是 cancel 方法会引发 InterruptedException。请检查取消后您的线程是否仍在运行？您确定没有尝试中断已完成的线程吗？您确定您的线程没有因任何其他异常而失败吗？尝试设置UncaughtExceptionHandler。