Блокировка ввода-вывода в Akka

Question

В последнее время я делаю некоторые Akka и удивляюсь: могу ли я блокировать ввод-вывод в Акке, не вдаваясь в большие проблемы? Скажем, у нас есть Актер, который делает некоторые блокирующие операции ввода-вывода, потому что он использует устаревшую библиотеку или по любой другой причине: не могу ли я просто использовать специальный диспетчер для тех Актеров, которые имеют достаточно размерный ThreadPool и блокируют ввод-вывод без блокируя всех других участников, потому что они работают с другим диспетчером?

Каковы недостатки этого? И какой был бы оптимальный способ вызова стороннего HTTP-API от актера?

Answer 1

Выполнение блокировки IO - это плохая идея в целом и в реактивной многопоточной среде, в частности, поэтому ваш первый шаг - попытаться избежать этого alltogether, что означает поиск в использовании AsyncHttpClient или HttpAsyncClient.

Если это не сработает, вы можете как минимум снизить риски, предоставив блокирующим актерам свои собственные потоки. Это, конечно, будет дорогостоящим, и вы по-прежнему рискуете заполнить свои почтовые ящики, но это выбор использования блокировки ввода-вывода.

Возможно, вам захочется посмотреть на модуль IO Actor для более сырого интерфейса для сетевого ввода-вывода.

Надежда все это помогает,

Cheers, √