Java8完整的未来

Question

我的问题是如何使用Completable Future。

我有一个实现Callable的类。

public class Executor implements Callable<Collection>

早点用来做——

service.submit(collectorService);

这将返回未来

那么，当可调用线程完成时，我如何使用可完成的未来并调用一个函数说isDone（）。




Answer 1

如果我没理解错的话，你想知道如何提交一个“任务”(你之前的“执行人”)，回馈一个CompletableFuture。

你通过打电话来做到这一点

CompletableFuture.supplyAsync(collectorService)

不同之处在于，您的“执行者”必须立即实现供应商，而不是可调用的

Answer 2

您可以创建调用现有collectorService的lambda表达式。未来可完成的供应商lambda表达式。SupplySync将接受以下内容：

 Supplier<Collection> supplier = () -> collectorService.call();

并可与CompletableFuture一起使用，如下所示

  CompletableFuture.supplyAsync(() -> collectorService.call(),service)
         .thenApply(collection->isDone(collection);

正如其他人指出的，当collectorService.call()方法返回结果时，将在执行我们未来任务的同一线程上执行应用。使用ApplyAsync会将另一个任务重新提交给executor服务(原始性能要慢一个数量级，所以除非你也有充分的理由，否则不要这样做！).

Answer 3

给定一个可操作的未来

f.thenApply(result -> isDone(result));      // sync callback
f.thenApplyAsync(result -> isDone(result)); // async callback

...或者，如果你不需要这个结果:

f.thenRun(() -> isDone());
f.thenRunAsync(() -> isDone());