Scala 期货和多线程

Question

我是 Scala 新手，我正在尝试处理期货和多线程

我有一个单线程版本的程序，可以对矩阵进行一些计算

SingleThreadCalc {
  def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = Future{doMath(matrix)}
}

我现在想要的是制作它的多线程版本。 只传递一个带有多个线程的 ExecutionContext 就足够了吗？

MultiThreadCalc {
  def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = 
Future{doMath(matrix)} (ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)))

这会在所有线程之间分担计算负载还是根本不发生？

Answer 1

简短回答：不。

长答案：

object MultiThreadCalc {
 def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = 
    Future{doMath(matrix)}(ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)))
}

上面的代码将在每次调用run 时分配一个永远不会关闭的新线程池，并将用于执行单个方法doMath（因此该池中只有一个线程将被使用）。

现在，如果您想并行执行 doMath 本身，则需要修改 ts 定义以使其可并行化，可能通过使其采用 implicit ec: ExecutionContext 参数并在其定义中使用该参数。

但如果您希望能够并行运行多次doMath 调用，则可以执行以下操作：

object MultiThreadCalc {
  def run(matrix : Seq[Seq[Double]])(implicit ec: ExecutionContext) : Future[Seq[Seq[Double]] = Future{doMath(matrix)}
}

然后在“外部”上创建一个可能ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)) 的 ExecutionContext，并在您想在其上执行逻辑时使用它。