主页 / 问题 / 1141569
Accepted
Konstantin
Asked:2020-06-16 14:48:53 +0800 CST2020-06-16 14:48:53 +0800 CST

使用具有未来的列表

  • 772

有一个包含 5000 个项目的列表。我想通过 Future 并行化列表处理过程。我尝试过的选项之一是在每次迭代中通过 Future 执行。我使用 fixedThreadPool(10) 作为 ExecutorContext。查看代码

    val list = List("Ivan", "Sergey", "Victor")
    for(name <- list) {
      Future { //do something with name }
    }

无法正确处理。尝试添加每个名称和基础 - 添加所有列表的一小部分。这可能是因为我没有等待 Future 执行。为什么会发生这种情况以及如何正确并行化列表中的工作？谢谢你。

scala

1 个回答

  1. Best Answer

    没错，Future您在单独的线程中创建和执行。我们需要Await一个在主线程中等待它们的人。

    val list = List("Ivan", "Sergey", "Victor")

import scala.concurrent.{Await, ExecutionContext, Future}
import java.util.concurrent.Executors
import scala.concurrent.ExecutionContext

    我们创建了一个单独的线程池，特别是对于我们的列表：

    val pool = Executors.newFixedThreadPool(10)
val context = ExecutionContext.fromExecutor(pool)

    在这里，我们通过名称浏览整个列表并在不等待完成的情况下运行它们：

    val seqOfFutures: List[Future[Unit]] = list.map { name =>
  Future { /* do something with name */ }(context)
}

    我们创建另一个Future等待整个列表的列表：

    import scala.concurrent.ExecutionContext.Implicits.global

val sequenceFuture: Future[List[Unit]] = Future.sequence(seqOfFutures)

    Future我们将等待的正是这个：

    Await.result(sequenceFuture, Duration.Inf)
pool.shutdown()

    英语

    • 3

相关问题