Akka 文档说：
您可能很想将阻塞调用包装在 Future 中并使用它来代替，但是这种策略太简单了：当应用程序在负载增加的情况下运行时，您很可能会发现瓶颈或内存或线程不足。
他们提出了以下策略：
在Future 内执行阻塞调用，确保在任何时间点此类调用的数量都有上限（提交无限数量的此类任务将耗尽您的内存或线程限制）。
在Future 内执行阻塞调用，为线程池提供适用于运行应用程序的硬件的线程数上限。
您知道这些策略的实施吗？
【问题讨论】：
标签： scala concurrency future
期货在execution contexts 内运行。这在Future API 中很明显：任何涉及将一些回调附加到未来或从任意计算或另一个未来构建未来的调用都需要一个隐式可用的ExecutionContext 对象。因此，您可以通过调整它们运行的 ExecutionContext 来控制未来的并发设置。
例如，要实施第二个策略，您可以执行类似的操作
import scala.concurrent.ExecutionContext
import java.util.concurrent.Executors
import scala.concurrent.future
object Main extends App {
val ThreadCount = 10
implicit val executionContext = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(ThreadCount))
val f = future {
println(s"Hello ! I'm running in an execution context with $ThreadCount threads")
}
}
【讨论】：
scala.concurrent 库更具有 Scala 风格。
Akka 本身实现了这一切，您可以将阻塞调用包装到 Actors 中，然后使用dispatchers 来控制执行线程池。
【讨论】：