在Scala阻止通话的期货

发布时间：2020-12-16 18:59:54 所属栏目：安全来源：网络整理

导读：Akka文件说： you may be tempted to just wrap the blocking call inside a Future and work with that instead,but this strategy is too simple: you are quite likely to find bottlenecks or run out of memory or threads when the application runs u

Akka文件说：

you may be tempted to just wrap the blocking call inside a Future and work with that instead,but this strategy is too simple: you are quite likely to find bottlenecks or run out of memory or threads when the application runs under increased load.

他们建议以下策略：

>在未来进行阻止呼叫,确保任何时间点上此类呼叫的数量上限(提交无限制的任务数量将耗尽您的内存或线程限制).
>在未来进行阻塞调用,提供线程池的上限,该线程池适用于运行应用程序的硬件的线程数.

你知道这些战略的实施吗？

解决方法

期货在 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")
  }

}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!