使用Scala进行并行/并发API调用的简单（最好是OO）方法？答案

【问题标题】：Simple (preferably OO) method to make parallel/concurrent API calls using Scala?使用Scala进行并行/并发API调用的简单（最好是OO）方法？
【发布时间】：2018-11-06 21:13:08
【问题描述】：

我的应用程序现在要求我每分钟调用数千次 API 来检查更新。我以前从未做过这样的事情，并且非常迷茫/努力开始。我查找了各种可能有帮助的框架/库。我看过最推荐的 HTTP4S 之一，但我完全糊涂了，因为我从未做过任何函数式编程，而且我现在没有时间学习这个。我不理解任何示例，并且对于使用我无法理解的内容非常犹豫。我还查看了 Akka 库、STTP 和 play ws，但再次被这些示例弄糊涂了。

我想我只是寻求一些帮助，也许是一个使用简单库进行并行 API 调用的示例。

编辑在我正在尝试做的事情下面添加一些半伪代码

import scala.collection.mutable.ListBuffer 

object TestObject {

  def main (args: Array[String]): Unit = {

    val customers: ListBuffer[Customer] = DBSingleton.getCustomers

    for(customer <- customers) {
      val response = doApiCall(customer)
      if(response == "Yes"){
        doTheOtherThingForThisCustomer(customer)
      }
    }
  }
}

但我不想在 doApiCall 上等待来自 API 的每个响应，而是希望同时为每个客户调用它。

【问题讨论】：

给我们尽可能多的代码。我们不知道你在用这些 API 调用做什么，或者它们需要什么样的参数。假设您有一个名为 doApiCalls 的函数，它可以工作，然后用它编写其余代码，以便我们更好地了解发生了什么。

标签： scala

【解决方案1】：

看起来doTheOtherThing() 没有返回任何有意义的东西，所以你可以这样做：

import concurrent.Future

...
for (customer <- customers) Future {
  val response = doApiCall(customer)
  if(response == "Yes"){
    doTheOtherThingForThisCustomer(customer)
  }
}

【讨论】：

刚刚测试过它看起来应该可以工作。谢谢。
我给你了 jwvh。我很抱歉。感谢您的帮助。在宣布您的答案被接受之前，我仍然会等待一天左右的时间来获得其他答案。
同意。明智的选择。