如何使用Akka actors处理Java futures

Question

我在Java web应用程序中有一个分层体系结构。UI层只是Java，服务是Akka类型的actor，外部服务调用(WS、DB等）包装在Hystrix命令中。

AkkaFuture future = service.getSomeData();

public AkkaFuture getSomeData() {
    return future {
        JavaFuture future = new HystrixCommand(mapSomeData()).queue()
        //what to do here, currently just return future.get()
    }
}

问题是，我想释放服务参与者正在使用的线程，而只是绑定Hystrix使用的线程。但是java的未来阻止了这一点，因为我必须阻止它的完成。我能想到的唯一选项（我不确定我喜欢）是不断地轮询Java future（一个或多个），并在Java future完成时完成Akka future。

注意：这个问题与Hystrix本身并不相关，但如果有人提出了一个与Hystrix相关的解决方案，我决定提到这个问题。

Answer 1

Java futures在设计上不如Scala futures。例如，看一看讨论“我如何在Akka Future中包装一个java.util.concurrent.Future”。

但是：也许Hystrix提供了某种oncomplete回调，而不是轮询（如上面讨论中所建议的）？我完全不知道这个库，但无意中发现了Hystrix API中的oncomplete。也许有用？