FutureTask 的自定义取消答案

【问题标题】：Custom cancel for FutureTaskFutureTask 的自定义取消
【发布时间】：2010-10-27 12:24:14
【问题描述】：

我已经实现了自定义取消逻辑，如实践中的并发中所述。

Encapsulating nonstandard cancellation in a task with newTaskFor。

这工作正常，我可以在未来调用取消，任务按预期取消。我需要能够通过调用“shutdownNow”方法来销毁我正在使用的执行程序服务，但是这个方法只是在线程上调用中断，这意味着我的自定义取消逻辑永远不会被调用。由于我的任务使用非阻塞套接字中断线程不起作用，因此我有自定义取消逻辑。

是否有一个简单的解决方案可以取消所有正在进行的任务。我尝试覆盖 ThreadPoolExecutor 上的关闭方法，但我无权访问工作人员列表。我希望能够通过关闭执行器来取消所有操作，因为它在多个地方用于提交任务，有没有简单的解决方案？

【问题讨论】：

是的，试过了，如果你看一下shutdownNow的实现，它只是调用thread.interupt，并没有委托给未来的cancel方法。

标签： java concurrency

【解决方案1】：

正如 John 所指出的，最好让您的任务可中断。然后你可以简单地依靠 ThreadPoolExecutor 来中断所有工作线程以进行有序的取消。

如果这不可能，你可以在 ThreadPoolExecutor 中添加额外的逻辑来实现你想要的。它有点涉及，对某些人来说可能并不漂亮（并且可能会损害性能），但我认为它会完成工作。我认为基本上你需要自己维护一个活动任务列表。关键是重写 beforeExecute() 和 afterExecute() 方法：

public class MyExecutor extends ThreadPoolExecutor {
    private final Queue<RunnableFuture> activeTasks = 
            new LinkedBlockingQueue<RunnableFuture>();
    ...

    protected void beforeExecute(Thread t, Runnable r) {
        RunnableFuture task = (RunnableFuture)r;
        activeTasks.add(task);
    }

    protected void afterExecute(Thread t, Runnable r) {
        RunnableFuture task = (RunnableFuture)r;
        activeTasks.remove(task);
    }

    public void cancelAllActiveTasks() {
        for (RunnableFuture f: activeTasks) {
            f.cancel(true); // invokes your custom cancellation logic
        }
    }

您也可以调用 cancelAllActiveTasks() 或覆盖 shutDownNow() 来调用它。我不喜欢的一件事是必须从队列中删除任务，因为它不是一个恒定时间的操作。

【讨论】：

点了。可以选择不同的集合，例如 LinkedBlockingQueue。 Remove() 在很多方面都不漂亮。 :)
是的，很抱歉我点击了周围并意外删除了评论
这是我得出的结论，并且目前已经实现了类似的。将查看是否有任何其他解决方案或将接受此答案。谢谢
您可以使用并发集。使用 CouncurrentHashMap 作为集合就可以了。