ExecutorService的未来任务并未真正取消

Question

我将我的期货从ExecutorService推送到哈希图中。以后，我可以从哈希图中调用期货取消。尽管结果是正确的，但后来我在Callable过程中命中了断点，就好像Future
cancel（）无效。我认为这里可能是两个不同的引用的情况（即使在断点时引用ID被列出为相同），但我想知道是否有些专家可以插手。代码如下所示：

ExecutorService taskExecutor = Executors.newCachedThreadPool();
Map <String, Future<Object>> results = new HashMap <String, Future<Object>>();

Future<Object> future = taskExecutor.submit(new MyProcessor(uid));
results.put(uid, future);

我允许处理继续进行（这是一个在任务传入时提交任务的循环），以后我可以尝试通过调用此方法从外部源中取消：

public static synchronized boolean cancelThread(String uid) {
    Future<Object> future = results.get(uid);
    boolean success = false;
    if (future != null) {
        success = (future.isDone() ? true : future.cancel(true));
        if (success)
            results.remove(uid);
    }
    return success;     
}

但是在调用future.cancel（）之后，我仍然在MyProcessor.call（）中遇到“无法取消”的路径-即它并没有真正被取消。

我在哪里错呢？有更好的办法吗？

Answer 1

后来我在Callable过程中命中了断点，就好像Future cancel（）无效。

Future.cancel(true)删除队列中尚未运行的作业，但如果该作业已在运行，则html" target="_blank">执行Thread.interrupt()。这将中断位的线程上，并导致任何sleep()，wait()和其他一些方法抛出InterruptedException。

要认识到它确实是很重要的 不 停止线程。您需要主动检查线程循环中的中断标志或正确处理InterruptedException。