Как правильно построить будущее Twitter

Question

Мы используем Finatra и имеем сервисы, возвращающие Twitter Future. В настоящее время мы используем либо Future { ... }, либо Future.value(..), чтобы построить Future экземпляров, но, глядя на источник, это не выглядит правильным.

В Future.apply источник doc говорит: «что в вызывающем потоке выполняется a, и поэтому необходимо соблюдать осторожность при блокировании кода».

Итак, как создать Future, который выполняет функцию в отдельном потоке, как это делает Scala Future?

Answer 1

Для этого вам нужен FuturePool. Что-то вроде val future = FuturePool.defaultPool { doStuff() }

И Future.value, и Future.apply являются незамедлительными. Они более или менее эквивалентны scala.concurrent.Future.successful.

Answer 2

+1 к ответу Димы, но ...

Поступать в фоновом потоке (FuturePool), потому что ваш сервер пытается не отставать от запроса нагрузки обычно не правильное решение. Предполагая, что вы просто обрабатываете задачу с интенсивным процессором в течение 100 мс, возможно, лучше сохранить ее в одном потоке и отрегулировать количество серверов, которые у вас есть, и количество запросов на обслуживание потоков.

Но если вы делаете что-то вроде запроса к базе данных или удаленной службе, этот вызов в идеале возвращает действительно асинхронное Будущее, которое не блокирует нити finagle.

Если у вас есть API-интерфейс sync, который обертывает сетевую услугу, то FuturePool, вероятно, является правильной вещью для ее устранения.