1回答
据我所知，Future.wait接受一个期货列表，并在该列表中的所有期货都完成时返回已完成的期货列表。
是否有一种方法可以阻止和等待列表中的任何未来完成，而不是等待它们全部完成？
浏览 5提问于2015-12-07得票数 4
回答已采纳
1回答
我很好奇递归构建Akka期货链的最佳方法，如果将来的doWork调用失败，那么未来应该被重试3次，如果没有重试尝试，那么链就会失败。我会更好地递归地建立一个期货列表并减少它们吗？
浏览 2提问于2014-06-19得票数 4
1回答
我想创建一个结果的列表，从几个“询问”的一系列阿克卡演员。从本质上说，我有一个期货列表，我想用这些结果填充一个列表，然后在所有期货返回时执行下一个操作。示例:我希望创建已完成列表的对象的类型期货清单来自： context.children.map("foo"))(5 seconds) }
浏览 2提问于2014-04-04得票数 2
回答已采纳
方法说明：
给定期货fs的列表，返回持有来自fs的所有期货价值列表的未来。返回的未来只有在fs中的所有期货都完成之后才能完成。列表中的值与对应的期货fs的顺序相同。如果任何期货fs失败，由此产生的未来也会失败。
浏览 2提问于2013-11-27得票数 7
回答已采纳
我已经启动了一个在Scala上编写异步PostgreSQL驱动程序的项目，要成为异步的，我需要接受回调并使用将来，但是接受回调和未来会使代码变得很麻烦，因为您总是必须发送回调，即使它是无用的。"insert a row in the database" in {
(handler, future) => handler.sendQuery( this.create ){ query => }.get( 5, Time
浏览 0提问于2012-03-10得票数 3
回答已采纳
2回答
直到最近，我一直在与Google和ListenableFutures进行广泛的合作，而我一直发现缺少的是一种为将来的完成提供无序流处理程序的方法。我所设想的是一个可迭代的，它阻塞了next()，直到另一个未来的返回。如果不是，我的想法是利用ListenableFuture的回调功能将结果推送到BlockingQueue上。目标是在返回值返回后立即处理它们。Futures.successfulAsList()很棒，但是在返回之前等待所有的值，而不是让我安排其他有用的工作。
浏览 2提问于2012-09-03得票数 4
回答已采纳
2回答
函数不等待异步函数。
、、、、
我需要函数_get_datos_restaurante()等待其他函数(_get_nombre_provincia()和_get_valoracion_media() )结束，但我无法做到这一点。问题是变量valoracion_media在_get_datos_restaurate()结束时不能正确地“操作”。这些函数是异步的，我在FutureBuilder中使用的是FutureBuilder()，所以我不知道是什么错误。这是我的代码：
Future<void> _get_datos_restaurante(String id, QueryDocumentSnapshot r) a
浏览 8提问于2022-03-16得票数 0
我想知道在invokeAll方法中，是否可以确保输出(Future对象)顺序与输入(Callable列表)相同。
浏览 4提问于2015-12-08得票数 5
回答已采纳
2回答
期货执行表
、、
它有助于减少代码，并提供功能语言的元素来处理数据。然而，我很难找到一种并行执行第一批期货的方法。我的列表是List[FutureString]类型的。如何使这个列表并行执行？
浏览 0提问于2015-09-14得票数 1
回答已采纳
2回答
我在一个方法中有一些scala代码，如下所示： val future2: Future[List[String]] = methodB()}def testMethod = Action {
val future1: Future[Lis
浏览 3提问于2014-04-08得票数 1
回答已采纳
我们使用Hazelcast作为缓存，并希望从一张地图中读取50个项目的列表。目前，我们看到了相当长的延迟阅读这个列表~20毫秒。读取单个条目非常快，但这似乎是非常糟糕的。我尝试使用Imap方法
.getAll(setOfKeys)Iterating列表并调用.get(singleKey)，为每个迭代列表，调用.getAsync(singleKey)，然后迭代期货列表，以获得是否有更好的方法来做到这一点，或者我是否需要重新考虑我们缓存/使用Hazelcast的方式，以某种方式将地
浏览 1提问于2020-02-13得票数 0
1回答
我有一个Java程序，需要将大量的大行插入到Server数据库中。行数为800 k，每个行的大小约为200字节。我尝试将批划分为(例如)5个组，并使用线程并行处理每个组。这非常快
我的问题是如何使线程使用变得健壮。特别是，如果任何批处理失败，都会引发异常。我希望捕获该异常并将其传递给调用方，并且我希望100%确定其他线程在我们传递之前已经完成(或者中止了，或者已经完成)。因为在程序后面从异常恢复时
浏览 2提问于2012-03-13得票数 4
给定一个期货集合，例如list>，我们如何将它们合并到一个期货地图中，而不会在Kotlin中阻塞。我不能使用get或join。为了阐明我想做什么: T的可完成的未来的列表，使之成为具有T的列表的可计算的未来。
浏览 21提问于2020-06-11得票数 0
回答已采纳
2回答
大多数时候，我的FutureT操作依赖于链中以前的未来。我大部分时间都在使用带有模式匹配的flatMap函数。例如； case None => Future.successful(NotFound("No user with given id")) case None => Future.successful(NotFound("No address with given
浏览 0提问于2017-06-23得票数 1
1回答
期货上市最有效的方式
、、、、
我通过一个对象列表调用异步客户端方法。该方法返回未来。
在调用后返回的期货列表中，什么是最好的迭代方式(以便处理那些最先出现的期货)？
浏览 1提问于2017-04-05得票数 8
回答已采纳
3回答
前几天，我在Vert.x期货上遇到了一个奇怪的问题，它并没有破坏代码，但仍然困扰着我。List<Future<YourClassName>> future = ...
但是似乎不能处理参数化的列表，并强迫您删除参数。是否有任何方法可以使参数化的期货列表与CompositeFuture一起工作，还是我们只需忽略这一警告？它不会破坏任何东西，但仍然是很好的解决
浏览 6提问于2017-01-04得票数 11
回答已采纳
1回答
我有一张桌子/列表，我翻阅。当元素变得可见时，我生成期货以显示计算结果。但是，如果我(最终用户)快速滚动，一些结果将“滚动出视图”，不再需要。这可能是一个很大的数字，并将严重推迟期货(结果)的回报，这些期货(结果)将有用地显示在当前可见的元素中。能做点什么吗？
干杯，史蒂夫
浏览 6提问于2015-02-20得票数 1
回答已采纳
2回答
void process(String question){
Future<ResponseList>task1 = executorService.submit(callable1);
Callable<ResponseList> callable2 = () -> this.dssmCo
浏览 0提问于2018-11-03得票数 1
回答已采纳
我有以下内容： final JobsResult jobsResult = restClient().getJobs(); final List<JobDetails> jobDetails = jobIds.stream().map(jobId -&g
浏览 0提问于2016-06-26得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
