如何在不阻塞的情况下运行一个期货序列并等待完成？
我在Scala中有一个要求，即运行一系列http调用，这些调用必须按顺序完成且不阻塞。我怎样才能做到这一点？
共有1个答案
您想看看foldLeft函数或包含一系列调用或其规格的TraversableLike：
val seriesOfOrderedCalls = Seq(..)
val eventuallyCompleted = seriesOfOrderedCalls
.foldLeft(Future.successful(()))((prev, call) => {
prev.flatMap { _ =>
// do your call here
// then return the future of the call
Future.successful(())
}
})
-
问题内容： 我有两个分开的阻塞队列。客户端通常使用第二个阻塞队列中的第一个来检索要处理的元素。 在某些情况下，客户端对两个阻塞队列中的元素感兴趣，无论哪个队列首先提供数据。 客户端如何并行等待两个队列？ 问题答案： 您可以尝试在某种循环中使用该方法，以仅在指定时间量内等待一个队列，然后再轮询另一个队列。 除此之外，我会说在另一个线程上为每个队列运行阻塞操作并为您的主应用程序提供回调接口是另一个稍微
-
我有一个存储库，它返回一个流量，并希望将结果设置为另一个需要列表的对象。有没有其他方法可以在不阻塞的情况下以列表的形式获取结果？ 这座大楼正在运转，但需要很长时间。
-
假设我有几个未来，需要等到它们中的任何一个失败或全部成功。 例如：设有3个期货：、、。 > 如果成功而失败，我不会等待（并将失败返回给客户端）。 如果＜code＞f2＜/code＞失败，而＜code＞f1＜/code＞和＜code＞f3＜/code＞仍在运行，我不会等待它们（并返回故障） 如果成功，然后成功，我继续等待。 你将如何实现它？
-
问题内容： 该代码选择同一文件夹中的所有xml文件，作为被调用的可执行文件，并以异步方式将处理应用于回调方法中的每个结果（在下面的示例中，仅打印文件名）。 如何避免使用sleep方法阻止main方法退出？我在解决问题时遇到了麻烦（我想这就是同步结果所必需的），因此，我们将不胜感激！ 问题答案： 您可以使用sync.WaitGroup。引用链接的示例：
-
我正在使用java Callable和ExecutorService执行计算： 我想让任务运行最多2分钟。但如果我打电话： 然后它就会立刻封锁！不要让我为其他任务分配超时，直到超时结束。 我可以用 但它返回的是未来列表，我不知道什么任务属于哪个未来。
-
我需要为我的项目生成序列图。 我已经创建了类、具有适当签名的方法、从一个类到另一个类的方法调用等，但是，由于逻辑还没有实现，我无法真正运行web应用程序来通过跟踪获得序列图。 语言：Java IDE：Eclipse