java - 处理一种未来依赖于另一种未来的两种不同类型的期货的理想方法是什么？

Question

我正在查看 AKKA 的 Java Futures API，我看到了很多方法来处理同一类型的多个期货，但我没有看到任何可以处理不同类型期货的东西。我猜我让这比现在更复杂。

无论如何，假设我们有两个不同的 Actor：actorA 和 actorB。它们基于不同的类，并且各自返回不同的 Future。然而，actorB 依赖于来自 actorA 的 Future。是以下逻辑，如何最好地处理这种情况？

Future<A> a = actorA.sendRequestReplyFuture(...);

Future<B> b = actorB.sendRequestReplyFuture(a);

如果我们有一个actorAs 和actorBs 的列表呢？

Answer 1

为什么不像你一样将它们包装起来，而是稍微改变一下 - 将 a 的结果传递给 b。

Future a = actorA.sendRequestReplyFuture(...);

Future b = actorB.sendRequestReplyFuture(a.get());

这种安排只是意味着在完成actorB.sendRequestReplyFuture()之前不会被调用 actorA.sendRequestReplyFuture()。这没什么错，事实上，我喜欢你那里的模式。

Answer 2

警告，刚刚从内存中写入，可能无法编译 OOTB：

Future<B> b = actor.sendRequestReplyFuture().flatMap( new akka.japi.Function<A,Future<B>>() {
  public Future<B> apply(A a) {
     return actor.sendRequestReplyFuture(a);
  }
}