1回答
我有这样的代码： List<Mono> monoList = foo();try { .then() log.warn("error", e);
} 当所有的MONO都成功完成时，它工作得很
浏览 32提问于2019-12-13得票数 0
我有一个Mono < List <(一些自制的对象)>>方法，它接受一个URN列表的单个参数。根据URN的数量，我必须发出许多异步HTTP请求，每个请求都由Mono表示。由于我希望程序能够在运行此方法和执行所有请求时移动到程序的其他部分，如何压缩各种Monos并返回奇异Mono的结果？上面的代码显然不起作用，它只是希望能让我的问题更容易解决。我在网上找不到任何关于如何在不指定
浏览 2提问于2020-01-24得票数 1
回答已采纳
我有一个Mono的列表，有些完成了一些失败：Mono<String> success2 = Mono.just(error1"));List<Mono<String>> monos</em
浏览 2提问于2021-02-21得票数 0
回答已采纳
不合适的标题对不起。我想等到所有thread结果的状态。我可以使用ExecutorService.invokeAll和调用future.get() //来完成这一任务，这将等待for循环的结果，如果两者都提供了相同的功能，那么为什么两个不同的函数，请告诉我除了在
浏览 1提问于2014-12-06得票数 1
回答已采纳
我有一个作为List<Mono>的阻塞web请求列表，我想同时执行这些请求。List<Mono<Response>> monos = requests.stream().map(bodies -> prepareMono(body))Collectors.toLis
浏览 0提问于2019-08-14得票数 0
1回答
我正在做一个小型POC，我想看看greenlets如何处理共享对象。1, 1, 1, 1, 1, 1, 1]End
代码按预期工作，但最终发生了一些奇怪的事情，任务1再次启动，相应的函数start再次执行。不确定这是否是一个有效的行为，或者我在代码中遗漏了什么，以防止Greenlet再次启动。
谢谢是提前
浏览 2提问于2017-08-10得票数 1
回答已采纳
我用蓝知更鸟的承诺。这在文档中并不是很明确。假设以下假设所有实例都是适当的承诺： return [
model.getOtherModels()，那么catch中的err变量中会有什么内容？另外，如果model.getOtherModels首先抛出一个错误，它会导致一个响应被发送到客户机，还是会等待aHTTPRequest完成呢？随后，aHTTPReq
浏览 1提问于2015-04-30得票数 1
回答已采纳
为什么Task.WhenAll方法破坏正常流并在取消子任务的情况下抛出异常？这种行为有什么好处？
然后，我尝试了Task.WhenAny方法。我希望这两种方法都应该以同样的方式处理取消的任务:抛出异常还是不抛出异常。
浏览 6提问于2013-08-13得票数 5
回答已采纳
如何将Monos列表组合到单个Mono。现在，我打电话给5家服务，其中2家成功，但其中3家可能失败，我想了解所有失败和成功的情况。我试过使用Mono.zipdelayError，但它不是那样工作的。每当出现错误时，就会出现我的资源异常处理程序。
为了便于了解，我公开了一个rest，它将在内部调用多个返回monos的服务，我必须将这些调用的结果合并到一个Mono中。
浏览 0提问于2018-09-21得票数 0
想象一个需要时间的软件，它接收一堆文本文件(每个100+ MB )，处理它们并放入一个DB。我正试图通过使用更多的内核来优化它(这台机器精确地使用了8核，一个四核i7和超线程处理)。最初，我将线程池实现为一个FixedThreadPool，但是当我通过JVisualVM直观地检查线程的执行情况时，我意识到线程常常是空闲的。在此过程中，在任何时候都不会为池创建一个次级线程，其他内核也几乎是空闲的。真正有趣的是，执行while循环中其余内容的“主”工作线程
浏览 3提问于2014-02-20得票数 0
回答已采纳
2回答
在同步调用中执行异步任务
、、、
我想注册一个异步执行的用户。但是，调用函数的行为是同步的，因为只有在成功创建用户时，程序才会继续。目前的执行情况是： succeeded(result: succeed) })
在ViewController中，注册的启动方式如下： try signup
浏览 4提问于2016-09-03得票数 0
回答已采纳
2回答
我正在尝试将大量的numpy nd_arrays写入磁盘。每个元素都是ints的大小(~2048,2)的nd_array。数组有不同的形状。在小列表(~3400长)上，工作正常，完成速度足够快(<30秒)。当列表变大时，进程似乎不会做任何操作。RAM或磁盘活动没有变化。30分钟后我就停止了等待。
强制停止处理后
浏览 1提问于2019-01-02得票数 0
回答已采纳
我想让我的用户选择继续等待请求完成与否，并使用window.setTimeout()每隔30分钟检查一次。我已经尝试过location.href = '/newpage.aspx‘或者触发按钮的单击处理程序(它做类似的重定向)，在完成页面方法之前重定向用户，但没有效果。我可以立即发送用户到一个简单的html页面，但是重定向到任何涉及服务器端的aspx页面似乎会阻塞。当页面方法最终完成时，重定向就会成功</e
浏览 2提问于2011-01-22得票数 0
1回答
据我所知，Future.wait接受一个期货列表，并在该列表中的所有期货都完成时返回已完成的期货列表。
是否有一种方法可以阻止和等待列表中的任何未来完成，而不是等待它们全部完成？
浏览 5提问于2015-12-07得票数 4
回答已采纳
2回答
我们有一个在后台运行任务列表的webservice函数。当所有任务都完成后，它会返回。我重温了C# 5的函数。Task.Factory.StartNew(() => DoWork(row))); result.Add(task.Result);
task.Result等待单个任务完成我对此进行了测试，方法是向DoWork方法添加3秒的延迟，并验证它在10个任务<em
浏览 0提问于2012-10-04得票数 5
回答已采纳
我正在使用NSURLSession的dataTaskWithRequest下载一个文件。它是用gzipped压缩的，它会被自动解压。但是，我不希望它是-我想要gzipped的源码。
浏览 3提问于2016-12-09得票数 6
有一篇文章谈到了这个主题，但是它无法判断哪个值是由哪个任务返回的(假设某个网页响应比另一个更快)。任何帮助都将不胜感激。
浏览 1提问于2021-03-19得票数 0
回答已采纳
1回答
我有一个反应异步函数export const EcgSaveDpcRequestSPService = async (dataItem, filesData) => {里面，我有2个等待发布到2个SharePoint列表，然后一个异步forEach dataItem.dpcUpFiles.forEach(async (file, index) => {，有3个等待发布到其他Sharepoint列表。有些等待需要在他们之前发布结果。 我有一个:Promise.resolve(..，它只在添加更多
浏览 6提问于2020-08-14得票数 0
因此，我有几个未来，我想经营，即使有些失败，我希望所有人都有机会运行。所以如果我这么做了情况会是这样吗？我的推理是，每一个未来都会在其执行器中有自己的queed作业，因此，只要主线程没有先完成，所有的任务都会运行。我的问题是，我专门在.join() on .allOf()上，所以我的应用程序不会在运行所有东西之前结束
因此，allOf()语义混淆了我:无论成功</
浏览 1提问于2019-01-23得票数 7
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
