Scala фьючерсы и потоки

Question

Чтение исходного кода scala для scala.concurrent.Future и scala.concurrent.impl.Future, кажется, что каждая будущая композиция через map отправляет новую задачу для исполнителя. Я предполагаю, что это обычно запускает контекстный переключатель для текущего потока и/или назначение потока для задания.

Учитывая, что потоки функций должны проходить вокруг Фьючерсов между ними, чтобы воздействовать на результаты фьючерсов без блокировки (или без вникания в спагетти обратного вызова), разве эта «реактивная» парадигма очень дорога на практике, когда код хорошо написан модульным способом, где каждая функция только делает что-то маленькое и переходит к другим?

Answer 1

Это зависит от контекста выполнения. Таким образом, вы можете выбрать стратегию.

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

Сначала я проверил, что делает пул fork/join по умолчанию, регистрируя, какой поток был использован. В новых версиях Afaik иногда используется подающая нить. Тем не менее, я не знаю, используется ли это/применяется для будущих обратных вызовов scala.