Java Multithreaded App - 如何动态取消 Futures 对象

Question

我认为这是多线程 Java 应用程序的常见场景，因此我将在此处尝试对其进行描述。

在我的 Java 应用程序中，我有一个 threadExecutor 对象，它定义了一个包含 5 个线程的池。

ExecutorService threadExecutor = Executors.newFixedThreadPool(5);

sendCallables 方法负责将作业列表分配给执行器。
我用 ObjectX 跟踪一个 List。通过这种方式，如果用户想要中断/取消线程，我可以引用 Futures 列表。像这样:

Map<ObjectX, List<Future<String>>> map = new HashMap<ObjectX, Future<String>>();

public void sendCallables(ObjectX referenceObj, List<Callable<String>> list) {
    ...
    List<Future<String>> futureList = new ArrayList<Future<String>>();
    for(Callable<String> myCallableJob : list) {
        Future<String> future = threadExecutor.submit(myCallableJob);
        futureList.add(future);
    }
    ...
    map.add(referenceObj, futureList);
    ...
}

public void cancelFutures(ObjectX referenceObj) {
    ...
    List<Future<String>> list = map.get(referenceObj);
    for(Future<String> future : list) {
        future.cancel();
    }
    map.remove(referenceObj);
    ....
}

到目前为止一切顺利。

现在有些情况下不再需要执行提交的任务。
在这些情况下，应用程序应该智能/自动地做出取消任务的决定。
当用户 session 过期或特定流程(与提交的任务相关)在所有作业执行之前结束时，可以在 Web 应用程序中找到此类情况的示例。

所以基本上每次我的应用程序没有意义继续执行作业时，我都需要调用 cancelFutures(referenceObj)。当应用程序需要调用它时，我必须确定每种情况。

我想知道是否有更好的方法来做到这一点。

我在想 WeakHashMap一旦 referenceObj 不再被应用程序引用，就能够清理 Map 但这不会阻止 Futures 被执行，因为我仍然需要在它们上调用 .cancel() (一种与 WeakHashMap remove(对象)方法？)

Answer 1

我认为您提出的解决方案非常好。如果您真的非常想从 referenceObj 获取垃圾收集来驱动取消，那么您可以结合使用 Wea​​kReference 和 ReferenceQueue。

在您的执行助手类中声明其中之一。

ReferenceQueue<ObjectX> refQ = new ReferenceQueue<ObjectX>();

每次提交任务批处理时执行此操作

new WeakReference<ObjectX>( referenceObj, refQ ).enqueue();

有一个线程只运行此循环，该循环会拉出变得弱可达(符合 GC 条件)的对象并取消 future /任务。

while (true)
{
    // this blocks
    ObjectX referenceObj = refQ.remove().get();
    cancelFutures( referenceObj );
}