代码之家 › 专栏 › 技术社区 › konquestor

了解动态期货列表:Scala

concurrent.futures for-comprehension scala

konquestor · 技术社区 · 9 年前

我正试图用以理解执行系列期货清单。一个未来的输出变成了下一个将来的输入。下面是示例代码。

for {
      x <- plugins(0).execute(input)
      y <- plugins(1).execute(x)
      z <- plugins(2).excute(y)
    } yield z

上面的代码更像瀑布,每个插件(i)在一些输入上执行,并将输出传递给下一个插件。最后一个插件的输出是最终输出。 plugins是一个Seq of Plugin对象。execute方法返回Future。我想让上面的代码更通用,因为插件中的插件数量是动态的。我该如何实施它。

1 回复 | 直到 9 年前

Basit Anwer 9 年前

plugins.foldLeft(Future.successful(input)) { (resultFuture, plugin) =>     
  resultFuture.flatMap(plugin.execute(_))
}

这里使用了两种工具: foldLeft 和 flatMap

看看这些链接,看看你是否了解这些函数的作用

Future.successful 只需将输入包装到一个Future中,这样我们就可以像对待其他中间结果一样对待它。Undercore是lambda函数参数的快捷方式。写这篇文章的另一种方法是: resultFuture.flatMap { result => plugin.execute(result) } .

推荐文章

davidzxc574 · 将字符串缩放为字符

2 年前

yic_l · 什么是“!”在这个函数中是什么意思?

2 年前

Jelly · Scala:用于理解递归未来

2 年前

to.mane · Scala—如何使用接收对象作为参数的构造函数创建类

2 年前

bbgghh · 在scala中连接两个列表时如何处理不匹配的键

2 年前

OdiumPura · 使用JDBC(Sql server)查询tempview

2 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

2 年前

B. Bal · 在Scala中重用类成员

2 年前

RomanGoltsov · Scala、Cassandra、Quill、Need impl logget批处理模式

2 年前

S.Hashiba · 哪个名称空间是正确的,“com.typesafe.sbt”还是“com.github.sbt”?

2 年前