6
To jest kod, który działa. Wysyła wiadomość do aktora (Greeter) i czeka na odpowiedź. Ale blokuje bieżący wątek.Obchodzenie się z przyszłym sukcesem jako odpowiedź od aktora Akka
public class Future1Blocking {
public static void main(String[] args) throws Exception {
ActorSystem system = ActorSystem.create("system");
final ActorRef actorRef = system.actorOf(Props.create(Greeter.class), "greeter");
Timeout timeout = new Timeout(Duration.create(5, "seconds"));
Future<Object> future = Patterns.ask(actorRef, Greeter.Msg.GREET, timeout);
// this blocks current running thread
Greeter.Msg result = (Greeter.Msg) Await.result(future, timeout.duration());
System.out.println(result);
}
}
Jaki jest możliwym sposobem na mój przykład użyć future.onSuccess
aby uzyskać wynik bez blokowania bieżącego wątku dzwoni?