Подождите ответа актера на неопределенный срок в будущем akka java

Question

У меня есть код, не содержащий актера, который делегирует некоторые действия аккорду акки, и я хотел бы ждать ответа этого актера бесконечно, я имею в виду, пока этот актер возвращает ответ в любое время. Проблема в том, что я не знаю, как ждать бесконечно в будущем с помощью методов Pattern.ask и Await.result.

я бы что-то вроде этого:

Timeout timeout = new Timeout(Duration.inf()); 
Future<Object> future = Patterns.ask(actor, msg, timeout); 
String result = (String) Await.result(future, timeout.duration()); 

, но это не работает, потому что тайм-аута не принимает объект Duration в качестве параметра конструктора, он принимает только FiniteDuration objetcs ...

Любая идея?

Приветствия

Answer 1

Вы никогда не можете получить ответ, так как доставка сообщений не гарантируется на 100%. Таким образом, ожидание на неопределенный срок не является хорошим подходом - вы вполне можете оказаться в ожидании навсегда.

Возможно, вам нужен некоторый уровень таймаута (возможно, длинный, если он подходит), а затем резервный случай, когда вы повторно отправляете свой запрос по мере необходимости. Это будет более надежный способ справиться с этой ситуацией.

Answer 2

Отказ от ответственности: Я не очень опытен с Аккой.

Предложение: вы не можете отказаться от объекта таймаута и просто написать

Future<Object> future = Patterns.ask(actor, msg); 
Await.result(f, Duration.Inf); 

Либо это, либо использовать Timeout timeout = Timeout.never

Остерегайтесь, однако:

тайм-аут с бесконечной продолжительности. Никогда не будет тайм-аут. Используйте экстремальный предостережение с этим, поскольку это может привести к утечкам памяти, заблокированным потокам или , возможно, даже не поддерживается приемником, что приведет к исключению . (из документа Akka API)