如何确保将FutureTask的垃圾回收提交给ThreadPoolExecutor然后取消？

Question

我正在将Callable对象提交给，ThreadPoolExecutor并且它们似乎在内存中停留。

使用Eclipse的MAT工具查看堆转储，可以看到Callable对象FutureTask$Sync的 可调用
变量正在引用。这FutureTask$Sync是通过FutureTask的 sync
变量引用的。这FutureTask是由引用FutureTask$Sync的 这个$ 0 变量。

我已经阅读了有关此内容的内容，此处以及其他内容），并且似乎FutureTask可调用对象包装在ThreadPoolExecutor的commit（）上，它永远包含对可调用对象的引用。

我感到困惑的是如何确保FutureTask收集的垃圾被收集起来，以使其不再继续在内存中保留可调用对象，而不在内存中保留任何可调用对象？

只是为了提供有关我的特定情况的更多详细信息，我正在尝试以ThreadPoolExecutor一种允许所有提交的任务在需要时被取消的方式实施。我已经尝试了在SO和其他地方发现的几种不同方法，例如完全关闭执行器（使用shutdown()，shutdownNow()等），还保留期货收益列表，submit()并对其全部调用cancel，然后清除期货列表。理想情况下，我希望不必将其关闭，而是cancel()在需要时进行清理。

所有这些方法似乎都没有作用。如果我将可调用对象提交给池，则很有可能最终会卡住。

我究竟做错了什么？

谢谢。

编辑：

根据要求，这是ThreadPoolExecutor的构造函数。

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
    super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
}

经过进一步的测试后，我可以看到，如果让已提交给ThreadPoolExecutor的任务完成，则不会泄漏。如果我尝试以任何方式取消它们，例如：

shutdownNow()

或保存对将来的引用并在以后调用cancel：

Future referenceToCancelLater = submit(task);
...
referenceToCancelLater.cancel(false);

或者使用以下方法将它们从队列中删除：

getQueue.drainTo(someList)

要么

getQueue.clear()

或循环浏览保存的期货参考并调用：

getQueue.remove(task)

这些情况中的任何一种都会导致FutureTask停留在上面所述的位置。

因此，所有这一切的真正问题是，如何正确地从ThreadPoolExecutor中取消或删除项目，以便FutureTask被垃圾收集且不会永远泄漏？

Answer 1

我什么都无法工作，所以我想出了以下解决方案。这是一个大概的概述：我在ThreadPoolExecutor中创建了一个数组，该数组跟踪队列中的可运行对象。然后，当我需要取消队列时，我遍历并在每个可运行对象上调用了cancel方法。就我而言，所有这些可运行对象都是我创建的自定义类，它们的cancel方法只是设置了canceled标志。当队列提出下一个要处理的队列时，在运行该可运行对象时，它将看到已取消并跳过了实际工作。

因此，所有可运行的对象都会被取消，很快就被一个接一个地快速清除。

可能不是最好的解决方案，但它对我有用，并且不会泄漏内存。