《图森未来》专题

相关:java.util.concurrent.Future的scala.concurrent.Future包装器 这来自我的另一个问题： 如何将akka streams Kafka(reactive-Kafka)集成到akka http应用中？ 我有一个AKKA HTTP应用程序，我想在路由中的onComplete函数中向Kafka发送消息/产品记录，如下所示： 但是，on complete(p

我有以下方法，用于返回Play for Scala应用程序中的字符串列表： } 代码不会编译并出现以下错误，因为如果 access = 0，则结果不是 Future： 类型不匹配；找到：play.api.mvc.Result要求：scala.concurrent.Future[play.api.mvc.Result] 如何解决这个问题？

我遇到了一个关于Scala和多种未来收益的问题。f1和f2都是期货。f2期货基于从f1期货获得的值。 根据 f1 的结果，我要么在 if 语句计算结果为 false 时执行 Lookup（），要么返回 LookupResult），要么模仿默认的 LookupResult。 返回以下错误： 类型不匹配。必需:选项[B_]，找到:Future[(MyNode，Any)] 我只是没有正确映射结果吗？例如

我的问题可以通过下面的(简化的)例子得到最好的描述: 给定一个异步HTTP客户端，该客户端返回＜code＞Future 对资源A执行GET 一旦GET完成，就对资源B执行GET 我的具体问题是，如何从映射器中返回未来，而资源B必须为 返回一个< code>Future，而< code>Future#map方法希望我传递一个从提供的值同步映射的映射器。 从JavaScript世界的< code>Pr

我正在尝试在Symfony 2应用程序中使用Guzzle池。我之所以考虑使用它，是因为它能够同时发送并发请求。 然而，由于它本质上是异步的，我不确定如何在Symfony 2中将它作为服务使用。因为返回并不总是立即发生。 例如，让我们说我在Symfony中有一个名为Foo的服务，它有这样一些什么方法。 现在我像这样调用这个服务。 有没有办法解决这个问题。我真的很想使用Future，因为我需要异步功能

我有下面的方法，它使用Apache Commons Http客户机向给定的URI发送异步GET，并返回Future和响应。 CloseableHttpAsyncClient实现了Closeable，因此我使用try/resource结构。 下面您可以看到其用法： 问题是，当我调用get on a future时，它不会返回所需的HttpResponse。如果我使用重载的get（）方法，它将一直等待

我有一个未来[T]，我想在成功和失败上映射结果。 比如说 如果我使用< code>map或< code>flatmap，它将只映射成功的未来。如果我使用< code>recover，它将只映射失败的期货。< code>onComplete执行回调，但不返回修改后的未来值。< code>Transform可以工作，但是需要两个函数而不是一个部分函数，所以有点难看。 我知道我可以做出一个新的，并用或/

我得到这个错误： 我该怎么解决这个？ 我使用的是Scala 2.12.8和Vert.x 3.7.1 感谢提前！

假设我有一个并行度为n的ForkJoinPool设置，我称之为这样的并行计算： 我这样做是为了确保生成的线程是在工作池中创建的（我有需要隔离的系统的不同组件）。现在假设调用它的线程也在这个工作池中执行，我会： 1） 我是不是挡住了泳池里的一根线？如果我让n个线程都阻塞未来，同时尝试在工作池中安排任务，这会导致死锁吗？我不清楚ForkJoinPool中的“最大并行度”是否意味着（如果有n个未阻塞的任

我正在尝试转换

我用的是Scala 2.10，Akka 2.1和Play 2.1。当我向后端发送一个http请求时，我要求一个参与者计算一些东西。如果计算结果在超时之前返回，则返回计算结果，否则返回另一个字符串。请参阅下面的代码。 演员如下： 我的问题是，即使演员在超时之前完成，未来也不会“返回”任何内容，因此超时总是过期。我做错了什么？谢谢。

我想链一个完整的未来，使它在处理过程中扇出。我的意思是，我对一个列表有一个开放的、可完成的未来，我想对列表中的每一项进行计算。 第一步是调用m_myApi.get响应（请求，执行器）发出异步调用。 该异步调用的结果有一个getCandidates方法。我想并行分析所有这些候选者。 目前，我的代码以串行方式解析它们 我想要这样的东西：

我在映射时遇到一个问题： 马达。Java 查询“from motor”是一个classname。但它仍然不起作用。如何按id vnopol查询？

是否有一种方法可以在不阻塞事件循环的情况下等待一个未来完成？ 我知道这个错误通常意味着什么，但我不知道在这种情况下...我试图在谷歌上搜索它，但没有找到任何关于将哪份清单放在哪里的明确解释。和以前一样，除非是强制性的，我更喜欢一次学一件事。 那么，回到这个问题：“基本”Vert.x是否有一种方法可以在事件循环不受干扰的情况下等待未来？

< code>doTask()是一个方法，如果< code>previousStepResult成功，则该方法执行某些操作，否则记录并按原样返回< code>previousStepResult。下面的代码工作正常，并且< code>conclude()也被执行，但是只有在没有异常(错误)的情况下。但是如果有异常(处理得很好)，代码返回false。因此，在错误的情况下，下一步被称为罚款，如前所述，