Java从ExecutorService设置回调

Question

我有一个fixedThreadPool，我正在使用它运行一组工作线程，以实现具有许多组件的任务的并行执行。

当所有线程完成后，我使用方法（getResult）检索它们的结果（相当大），并将其写入文件。

最后，为了节省内存并能够看到中间结果，我希望每个线程在完成执行后将其结果写入文件，然后释放内存。

通常，我会在run（）方法的末尾添加这样的代码。但是，此类中的某些其他对象也调用这些线程，但不希望它们将结果写入文件-相反，它们使用它们的结果来执行其他计算，这些计算最终被写入文件。

所以，我想知道是否可以将回调函数附加到使用ExecutorService完成线程的事件中。这样，我可以立即检索其结果并在该场景中释放内存，但在其他场景中使用这些线程时不会破坏代码。

这样的事情可能吗？

Answer 1

ExecutorService#提交返回未来任务

ExecutorService executor = Executors.newFixedThreadPool(10);
Future<Long> future = executor.submit(new Callable<Long>(){
       @Override
       public Long call() throws Exception {
           long sum = 0;
           for (long i = 0; i <= 10000000l; i++) {
               sum += i;
           }
           return sum;
       }
});
Long result = future.get();
System.out.println(result);

Answer 2

您可以在Java 8中使用CompletableFuture添加线程返回的回调，如下所示，其中t是长期运行计算的结果，

CompletableFuture.supplyAsync(() -> {
    T t = new T();
    // do something
    return t;
}).thenApply(t -> {
    // process t
});

如果您只想在Java 7中使用回调，可以执行以下操作：，

int x = 10;
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(x);
Future<T> result = fixedThreadPool.submit(() -> {
    // do calculation
    return T;
});
fixedThreadPool.submit(() -> {
    long minutesToWait = 5;
    T t = null;
    try {
        t = result.get(minutesToWait, TimeUnit.MINUTES);
    } catch (InterruptedException | ExecutionException | TimeoutException e) {
        LOGGER.error(e);
    }
    if (t != null) {
        // process t
    }
});

Answer 3

如果可以选择使用Google Guava，则可以以下列方式使用ListenableFuture界面：

1. 通过更多执行器将执行器服务转换为ListingExecutorService。ListingDecorator（existingExecutorService）
2. 提交（可调用