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

Question

我正在向 ThreadPoolExecutor 提交 Callable 对象，它们似乎保留在内存中。

使用 Eclipse 的 MAT 工具查看堆转储，可以看到 Callable 对象被 FutureTask$Sync 的 callable 变量引用。 FutureTask$Sync 由 FutureTask 的 sync 变量引用。该 FutureTask 由 FutureTask$Sync 的 this$0 变量引用。

我已经阅读过有关此内容的内容（此处，这里，以及SO），看起来像可调用对象包装在 ThreadPoolExecutor 的 Submit() 上的 FutureTask 永远保留对可调用对象的引用。

我感到困惑的是如何确保 FutureTask 被垃圾收集，这样它就不会继续将可调用对象保存在内存中，并保存可调用对象可能在内存中保存的任何内容？

为了提供有关我的特定情况的更多详细信息，我尝试以允许在需要时取消所有已提交任务的方式实现 ThreadPoolExecutor。我尝试了在 SO 和其他地方找到的几种不同方法，例如完全关闭执行器（使用 shutdown()、shutdownNow() 等）并保留一个列表通过 submit() 返回期货的数量，并对所有期货调用取消，然后清除期货列表。理想情况下，我希望不必关闭它，只需 cancel() 并在需要时清除。

所有这些方法似乎都没有什么作用。如果我向池中提交一个可调用对象，它很可能最终会保留下来。

我做错了什么？

谢谢。

编辑：

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

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

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

shutdownNow()

或者保存对未来的引用并稍后调用取消：

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

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

getQueue.drainTo(someList)

或

getQueue.clear()

或 循环保存对 future 的引用并调用：

getQueue.remove(task)

任何这些情况都会导致 FutureTask 如上所述保留下来。

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

Answer 1

根据这篇文章，您可以调用在执行器上清除。

Answer 2

作为解决方法，您可以执行以下操作：

class ClearingCallable<T> implements Callable<T> {
    Callable<T> delegate;
    ClearingCallable(Callable<T> delegate) {
        this.delegate = delegate;
    }

    T call() {
        try {
            return delegate.call();
        } finally {
            delegate = null;
        }
    }
}

Answer 3

我无法得到任何工作，所以我想出了以下解决方案。以下是一个粗略的概述：我在 ThreadPoolExecutor 中创建了一个数组，用于跟踪队列中的可运行程序。然后，当我需要取消队列时，我循环遍历并在每个可运行对象上调用取消方法。就我而言，所有这些可运行对象都是我创建的自定义类，它们的取消方法只是设置一个取消标志。当队列提出下一个要处理的任务时，在可运行对象的运行中，它会看到它被取消并跳过实际的工作。

因此，当它看到它被取消时，所有可运行的东西都会被快速地一一清除。

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

Answer 4

请参阅：https://docs.oracle。 com/javase/7/docs/api/java/util/concurrent/Future.html

Future 表示异步计算的结果。如果不能使用 get 方法检索结果，则会发生内存泄漏！

如果您不想使用异步结果，请使用 Runnable 安装 Callable。