用于REST API调用的Scala ExecutionContext

Question

execution-context {
  fork-join-executor {
    parallelism-max = 10
  }
}

我有几个问题：

1. 这将创建10个专用线程吗？
2. 如何知道并行度的大小-最大值？
3. 假设我要使用这个执行上下文进行REST API调用，我应该如何调整它的大小？

Answer 1

>

这将创建10个专用线程吗？

很接近，但不完全是。从Akka文档中可以看到，三个属性Parallelism-min、Parallelism-Factor和Parallelism-max用于计算Parallelism参数，然后提供给基础的ForkJoinPool。公式为并行度=clamp（并行度-min,ceil（可用处理器*因子）,并行度-max)。

现在谈谈平行性。正如您可以从文档中读到的，它大致对应于“热”线程的数量，但在某些情况下可能会产生额外的线程。即当一些线程在ManagedBlocking中被阻塞时。阅读答案以了解更多细节。

这取决于您的用例。如果每个任务阻止一个线程，您期望同时执行多少个任务？

假设我要使用这个执行上下文来进行REST API调用，我应该如何调整它的大小？

再问一遍，您想同时发出多少个请求？如果您要阻塞线程，并且希望同时有大量http调用，并且希望尽快处理它们，则需要大型线程池。