ExecutorService的未来任务不会真正取消

Question

我将未来从ExecutorService推送到哈希映射中。稍后，我可以在散列图中调用Futures上的cancel。虽然结果是真的，但我后来在可调用过程中遇到了断点，好像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;     
}

但我仍然在MyProcessor中遇到一条“未取消”的路径。在future之后调用（）。调用了cancel（），即它实际上没有被取消。

这件事我哪里做错了？有没有更好的办法？

Answer 1

FutureTask:: 布尔取消（boolean mayInterrupIfRrun）将在当前正在运行的线程上执行中断。

FutureTask.java
public boolean cancel(boolean mayInterruptIfRunning) {
    if (!(state == NEW &&
          UNSAFE.compareAndSwapInt(this, stateOffset, NEW,
              mayInterruptIfRunning ? INTERRUPTING : CANCELLED)))
        return false;
    try {    // in case call to interrupt throws exception
        if (mayInterruptIfRunning) {
            try {
                Thread t = runner;
                if (t != null)
                    t.interrupt();     ////////////HERE/////////////
            } finally { // final state
                UNSAFE.putOrderedInt(this, stateOffset, INTERRUPTED);
            }
        }
    } finally {
        finishCompletion();
    }
    return true;
}

JavaDoc说下面是中断

html" target="_blank">public void interrupt（）中断此线程。除非当前线程中断自身（这是始终允许的），否则将调用此线程的checkAccess方法，这可能会导致引发SecurityException。

如果该线程在调用对象类的wait（）、wait（long）或wait（long，int）方法时被阻塞，或者在调用该类的join（）、join（long）、join（long，int）、sleep（long）或sleep（long，int）方法时被阻塞，那么它的中断状态将被清除，并将接收到InterruptedException。

如果该线程在可中断通道上的I/O操作中被阻塞，那么该通道将被关闭，线程的中断状态将被设置，线程将收到ClosedByInterruptException。

如果此线程在选择器中被阻塞，则将设置线程的中断状态，并立即从选择操作返回，可能返回非零值，就像调用了选择器的唤醒方法一样。

如果前面的条件都不成立，那么将设置该线程的中断状态。

中断不活动的线程不需要有任何效果。

抛出：SecurityException-如果当前线程无法修改此线程

结束；取消FutureTask只有在线程被阻塞时才会产生影响（在调用等待（）时，...）否则开发人员有责任检查Thread.currentThread（）. isInterunc（）退出；同时执行非阻塞操作。

Answer 2

我后来在Callable过程中碰到了断点，就好像未来取消（）没有效果一样。

未来。取消（true）删除队列中尚未运行的作业，但如果作业已在运行，则执行与线程等效的操作。在运行作业的线程上中断（）。这将设置线程上的中断位，并导致任何睡眠、等待和其他方法引发中断异常。

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

有关更多详细信息，请参阅此处我的SO回答：如何使用线程的id挂起线程？