《scala》专题

我想把这个val: 对它进行一些操作（我正在考虑展平） 然后得到这个结果 如果展平方法在这里不合适，那很好。只要我得到结果。 谢啦！

当一个函数依赖于一些未来的结果时，我一次又一次地挣扎。这通常归结为一个类似于Future[Seq[Future[MyObject]]的结果 为了摆脱这种情况，我现在在辅助函数中使用Aetc来获取一个非未来对象并减少嵌套。 它看起来像这样 这段代码有效，但对我来说，它看起来很笨拙。这两个映射调用是另一个缺陷。我花了几个小时试图弄清楚如何保持完全异步并返回一个简单的未来Seq。如何使用 Play2 最

我在我的实体类中具有以下关系，

我正在编写一段scala代码，其中第三方库返回一个Future[Boolean]对象，而我需要在我的scala代码中使用这个Future对象，这段代码完全是以同步方式编写的。 目前，我正在对第三方库操作执行Await.result，以确保它只返回布尔值。有没有更好的处理方法，我的scala代码需要一个布尔值来做进一步的操作？

我有一个监督Akka演员，它使用路由器将消息转发给工人演员。 我有一个封装了管理程序的类，当我调用该类的方法时，它“要求”管理程序做一些事情，然后我使用< code > await . result(the future)等待结果(没有结果我无法继续)。 如果worker抛出异常，我想重新启动抛出异常的worker，我想让调用包装类的代码捕获异常。 我向路由器构造函数传递了一个< code>One

我有一个等待未来结果的演员。在将来的Complete上调用会导致编译器错误: 错误：构造函数无法实例化为预期的类型 [scalac] 找到 ： akka.actor.Status.Success [scalac] required： scala.util.Try[Iterable[Any]] [scalac] case Success（result： List[PCBInstanceStats]）

以下代码通过使用print语句模拟在线购物。我正在使用Future来模拟一个场景，在该场景中，我同时将多个商品添加到购物篮中（我正在添加购物篮中的每个偶数商品）。我希望最后，代码会打印有多少商品已添加到购物篮中。 > 我创建了 5 个 Future 对象（因此我期望结果为 5 个） 我将每个未来存储在一个列表中。 我使用for循环来等待每个未来的完成 我希望在所有期货执行之后，我选择他们的成功对象

我有一个名为Source的类，它有lazy val isValid来做一些需要时间的网络检查。我让它返回Future[Boolean],这样它就不会阻塞主线程: 现在，我想检查几个来源并丢弃无效的来源。 下面是一些伪代码： 我在想一些方法，可以将从isValid返回的Future[Boolean]转换为其他将来，在验证检查完成后，可以使用整个源对象进行解析。 最好的方法是什么？

我有一个方法可以返回< code>Future -成功或失败，甚至可以抛出一个异常。我可以通过在整个方法上放置try catch块并始终返回Future来避免这种情况，但我现在想避免这种情况。我对调用这样的方法没有什么问题: 1）在调用方代码中，如果我使用，我希望执行一个方法，并期望一个未来或异常，我试图通过以下方式处理： 输出：（上面没有执行恢复或捕获块） 但如果我将＜code＞val fut1

我有一个自定义案例类异常： 在我的 dao 中，我有一个从数据库中提取对象的方法，该方法返回 future，如果此将来失败，我将抛出我的 RecordNotFoundException 异常： 在另一个方法中，我调用getPerson方法，所以我将恢复添加到另一个方法中，当未来使用RecordNotFoundException失败时，我想返回一些东西： 因此，基本上，我希望当getPerson失败

我必须从带有Scala的RESTAPI中获取给定列表中每个文件的问题列表。我想并行处理这些请求，并使用调度库来实现。我的方法是从Java框架调用的，我必须在该方法结束时等待所有未来的结果，以将整体结果返回到框架。这是我的密码： 这段代码有几个问题。首先，我没有得到我期望的< code>issuesByFile (1)的类型。如果< code>findLookUpId无法找到查找Id(即< code

我有一个由提供的Rest API。在某些情况下，我需要从外部数据库（）获取数据，如果数据库传递数据的时间太长，我希望查询失败。 一种简单的方法是将调用包装在中，然后使用具有所需持续时间的来阻止它。 似乎效率低下，因为这个实现需要两个线程。有没有有效的方法来做到这一点？ 我还有另一个用例，我想并行发送多个查询，然后聚合结果，具有相同的延迟限制。 同样的问题，最有效的实现方式是什么？ 多谢你的帮忙

我是一名spark Scala程序员。我有一份spark工作，其中包含完成整个工作的子任务。我想使用ToFutures并行完成子任务。一旦完成整个工作，我必须返回整个工作响应。 关于scala Futures，我听说一旦主线程执行并停止，其余线程将被终止，并且您将得到空响应。 我必须使用等待。结果以收集结果。但是所有的博客都告诉你应该避免等待。结果是，这是一个糟糕的做法。 正在使用等待。在我的案例

我试图将List[T]类型的值提取为映射中的T。例如： 会变成 以下是我到目前为止所写的内容： 这是我收到的错误： 编辑:该行出现以下错误: EDIT2:request.body。asFormUrlEncoded示例输出

在猫的Scala中： 每当我们为Future调用Functor时，无论是直接使用Functor.apply还是通过map扩展方法间接调用，编译器都会通过隐式解析定位futureFunctor，并在调用位置递归搜索ExecutionContext。这可能是扩展的样子: 好吧，我试试: 但有一个例外： 错误：（29， 10） 找不到参数实例的隐式值：cats。Functor[scala.concurr