future

假设我有一个返回CompleteableFuture[Data]的方法： def doIt(): CompleteableFuture[Data] = { ... } 而且，doIt() 可以返回 null 的可能性非零。我们如何在不阻塞调用线程的情况下调用doIt() 直到结果不是null？ Scala中的方法是什么？ 我目前的尝试： Future { var data: Dat... »

我有一个 SwingWorker，它启动一个 LinkedBlockingQueue，将它传递给另一个方法（PortalDriver，下面），然后在 doInBackground() 方法中读取它。 LinkedBlockingQueue 持有自定义对象的期货（并且它肯定是正确填充的）。作为检查，我正在创建的对象（通过 ExecutorService）在构造函数的末尾有一个 println(thi... »

在jQuery version of "Deferreds"（C++ 称之为“期货”）中，.then() 方法将其签名不包含任何期货的函数作为其参数。而为 C++17 (see N3721) 提议的 .then() 采用了一个在其签名中带有 future 的函数。 即，如果我想“在后台”计算f(g(x))，N3721 想让我写 extern int f(int); extern int g(i... »

我正在尝试使用此列表制作横幅，该列表可通过函数“getBannerList”访问，而不必在此轮播中手动编写列表 如果我通过在 items: ['base64string','base64string','base64string'].map 手动放置列表来设置项目，它会正常工作，但是当我用函数替换它时会导致此错误 错误 The following NoSuchMethodError was thr... »

在我的代码中，我解析 Json Album 文件。所以我有'contentIntro'和'title'的值。但我只能用这段代码显示其中一个。我的目标是在下面显示 title 和 contentIntro。 @override Widget build(BuildContext context) { return Scaffold( appBar: AppBar( ... »

我刚刚更新了 Flutter 并成功从git 下载了我的原始项目。现在我收到了一个奇怪的Future 错误。我在 github 上看到在线提到它，但没有关于如何修复的明确答案。该项目甚至没有加载。它从我的 main.dart 文件中读取 Future 语句并返回... [VERBOSE-2:dart_error.cc(16)] 未处理的异常：类型 “未来动态”不是“未来字符串”类型的子... »

df = df.loc[df['var'].isin(df2['this'].unique().tolist())] 上面的代码给了我一个 FutureWarning，我无法解决它。这是错误还是功能？ C:\Users\Username\AppData\Local\Continuum\anaconda3\lib\site-packages\numpy\lib\arraysetops.py:56... »

我一直在尝试不同的方法来处理结果断开连接的阻塞方法，同时保持可能已被中断的状态。我发现不得不处理发送和接收难以对齐的不同类和方法是令人沮丧的。 在下面的例子中，SomeBlockingMethod() 通常返回void 作为消息发送到其他进程。但相反，我使用接收结果的侦听器将其设为synchronized。通过将其转为线程，我可以wait() 获得超时或无限期的结果。 这很好，因为一旦返回结果... »

在 Play Framework 2.0.1 (Scala) 应用程序中，我们使用了一个 Web 服务客户端库，它返回 java.util.concurrent.Future 作为响应。 我们不想在 get() 调用中阻止 Play 应用，而是将 j.u.c.Future 包装在 akka.dispatch.Future 中，以便我们可以轻松使用 play 框架的 AsyncResult 处理。... »

在以下代码中，sn-p 调用getAmounts 以获取按货币分组的一些金额，然后调用getRates 以应用相应的汇率： def getAmounts = Future(Map("EUR" -> 500d, "USD" -> 400d)) def getRates = Future(Map("EUR" -> 1d, "USD" -> 0.9)) getAmounts.... »

就是这样。真的找不到更接近的东西。我想实现以下任务链 List<Item> items = Collections.singletonList(new Item("John Smith", "1997-2014")); Stream<CompletableFuture<List<ScrappingResult>>> scrappingFuture... »

我正在从我的 API 获取一些数据。我通过将返回的 JSON 转换为一些小部件 CommentaireSingle 来处理它们。 但是对于我来说，关于 build 方法，我有一些不清楚的地方。 每次构建小部件时都会调用 build，包括 setState 方法。 FutureBuilder 用于在内容完全加载后生成内容。 ValueChanged 用于将数据从子级传递给其父级。 所以我的问题是... »

我对 Scala 还很陌生，请多多包涵。我有一堆包裹在一个大数组中的期货。 Futures 已经完成了他们的辛勤工作，查看了几 TB 的数据，在我的应用程序结束时，我想总结上述 futures 的所有结果，以便我可以很好地展示它们。 我拥有的期货集合属于以下类型： Array[Future[List(String, String, String)]] 到目前为止，我所读到的所有关于理解的内... »

我被 CompletableFuture 异常处理困住了 我的逻辑是发送电子邮件并保存此操作的状态。如果发送电子邮件引发异常，我需要使用异常消息保存状态。 public interface MyService { CompletableFuture<Boolean> sendEmail(String content, String address); CompletableFut... »

我正在使用 Akka Streams，并且一直在尝试对从 MongoDB 集合中轮询的事件进行一些丰富和处理。但是，我对实现事件丰富器的最佳方法有一些疑问，这可能需要连接到外部数据源。 mapFuture 似乎很合适，但我遇到了一些问题： class EventEnricherActor extends Actor with ActorLogging { // ... def re... »

我有一个期货列表，在每个未来完成时，我都有一个应该执行的回调。 我正在使用 Futures.successfulAsList 检查是否所有的期货都已完成。但是，这并没有考虑到回调的完成。 有没有办法确保回调完成？ 代替回调，我可以使用 Futures.transform 包装到另一个 Future 并检查它是否完成。但是，有了这个，我无法访问包装的未来引发的运行时异常。 Listenin... »

我最近从 JAVA 8 开始使用 Typescript/Javascript 进行编程。一遇到async/await，它就让我想起了CompletableFuture。在java中，不管方法的返回类型如何，我都可以在方法内部调用someMethodReturningFuture.get()，可以随意阻塞执行。但是在 JavaScript 中，当我们想要使用 await 阻止其他一些异步方法时，为什... »

我在代码中使用异步 http 客户端来异步处理 GET 响应 我可以同时运行 100 个请求。 我只在容器中的 httpClient 实例上使用 @Bean(destroyMethod = "close") open fun httpClient() = Dsl.asyncHttpClient() 代码看起来像 fun method(): CompletableFuture<Str... »

我正在寻找一种现代方式来在给定日期/时间（尤其是ZonedDateTime）执行给定方法。 我知道 Timer 类和 Quartz 库，如下所示（线程包括完整的解决方案）： Java - Execute method on specific date [closed] Call a method at fixed time in Java 但是这些线程相当陈旧，从那时起就没有使用新的 Ja... »

我有检查 CompletableFuture 执行时间的方法。如果这样的 CompletableFuture 执行时间超过 2 秒，我想终止此任务。但是，如果我没有控制执行 CompletableFuture 方法的线程，我该怎么办？ final CompletableFuture<List<List<Student>>> responseFut... »