1回答
顺便说一句，我还在学习weblux；我不知道这是否可能，或者我有错误的方法，但考虑到这种并行的变化。Flux<String> enablers = Flux.fromIterable(enablersList) .的流结束，并处理其中的所有响应，原因是如果其中一个给我错误或负响应，我将不会为阻塞器运行另一个并行Flux
Flux<String>
浏览 69提问于2020-02-08得票数 0
我正在学习反应性编程，但我有一个疑问，我正在尝试执行以下代码，但我不明白为什么在订阅之前添加delayElements，没有打印元素import reactor.core.publisher.Flux<Integer> flux = Flux.just(1, 2, 3); }使用delayElements时，不会
浏览 34提问于2022-08-25得票数 0
2回答
在流中，必须根据特定字段并行解析消息。 void testParallel() {
Flux.just(new Order(1,1)
浏览 9提问于2022-05-28得票数 0
我有一个方法createComplianceResponse()，它返回BOLCompliance对象，在此之前，我更改为BOLCompliance的Mono，因为我必须调用它内部的另一个响应式服务。但在此之后，我当前调用此服务的服务在第6行和第7行出现错误。routeLink.getComplianceIds().isEmpty()) {
Mono<List<Compliance>> complianceList = Flux
浏览 64提问于2021-10-13得票数 0
回答已采纳
1回答
并行地迭代同一通量两次
、、、
例如：在flux1中只引用两次Mono.zip如果我将日志添加到flux1中，它似乎不是在并行运行，而是按顺序运行。
想知道是否有一种更简洁的方法，那么Mono.zip就可以避免在本例中创建一个flux1变量。theResultOfService2) -> ca
浏览 5提问于2022-02-26得票数 1
KafkaFluxFactory(Map<String, Object> properties) { }
.receiveAutoAck()
.flatMap(flux-> flux.groupBy(this::extractTopicPartiti
浏览 1提问于2017-06-16得票数 2
1回答
我试图弄清楚如何获取一个Flux，它是一个输入数据序列，并行地通过一个阻塞调用运行它们，这个阻塞调用可能会重新排序该序列，然后通过第二个单线程阻塞调用运行重新排序的数据。这个想法是，最后的单线程调用是将重新排序的并行工作输出记录到磁盘上。我试图做的事情的最终目的是，并行算法是一种协商一致的算法，它将决定数据输入的实际顺序。查看，它建议我将阻塞调用转换为运行在调度程序上的Mono，该调度程序为我提供并行或单线程处理：
privat
浏览 0提问于2019-11-05得票数 2
回答已采纳
1回答
我是反应式编程的新手，我有一段代码，只有在并行任务结束后才能并行运行，后面的代码应该被执行Flux.fromIterable( sourceOneMap.keySet); return new MissingCountResult( rtbmDao.findCount(), new Date() );
现在，当我运行我的代码时，步骤2首先被执行</e
浏览 2提问于2018-12-07得票数 0
1回答
Flux<Integer> flux1 = Flux.just(9, 8, 3, -2); Flux<Integer> flux3 = Flux.just(6, 5, 4, -4);
List<Flux<Integer>> list1 = Arrays.asLi
浏览 6提问于2021-04-06得票数 0
1回答
Flux<ServerResponse> feedResponses = request .mapfeed URLs .map(Flux但是，在调用Flux::merge之后，我不太确定该做什么。如有任何
浏览 85提问于2019-05-01得票数 3
回答已采纳
我想将同一类型的多个Flux组合在一起。在订阅时，它们应该并行执行。订阅方法应该能够限制请求的数量。
我用Flux.merge(..)和Flux.concat(..)做了实验。后者似乎强制执行顺序请求产生，即使在并行调度程序上发布时，当第一个元素以热切的方式请求所有元素时，并且只尊重onNext事件的onNext方法，而不是对onRequest事件，也是如此。三个Flux，它们都将在Schedulers.bounde
浏览 5提问于2020-04-16得票数 0
当某人有多个订阅并且其中一个抛出异常时，其他调用不会被执行。此外，异常被传播并从objectTopicProcessor.onNext("")抛出。我想阻止这样的行为。
浏览 0提问于2019-05-03得票数 0
1回答
我正在努力理解Flux.parallel()的工作。我的要求如下:有一个字符串stringList的列表，假设我们并行地对每个字符串执行一些任务，其中一个字符串需要一些时间，例如我在这里使用Thread.sleep，然后我想在Flux<String>中收集字符串，但在此之前，我需要确保所有并行字符串的执行是否已经完成。List<String> list = Arrays.asList("Mango", "Apple", &q
浏览 5提问于2022-01-24得票数 0
回答已采纳
1回答
petitionRequest).map(this.service::getDetails) Generated o = Generated.builder().info(c).detail(p).build();
浏览 0提问于2019-07-22得票数 2
回答已采纳
1回答
对于每个大小，我在自定义执行程序服务上并行执行所描述的flux。例如，我可能有5个大小，但在数据库中，系统只添加了4和5个大小。或者我在转换我的流时可能会出错。或者我可能在存储系统中有一个错误。
浏览 22提问于2020-05-12得票数 1
回答已采纳
我正在使用Flux.generate()创建一个通量。生成器(消费者)实际上是从消息队列中读取的。问题是这个调用需要相当长的时间(有时甚至需要1-2秒)。这将使通量停止处理。Flux.generate(vaultQueueConsumer) .runOn(Schedulers.parallel()) .subscribe(); 有谁知道如何使发电机并行吗？我不想使用Flux</em
浏览 60提问于2020-01-13得票数 3
回答已采纳
希望在不同线程上异步执行流中的元素。但是它没有在不同的线程上执行它们。我错过了什么吗？
return Flux.fromIterable
浏览 2提问于2019-11-12得票数 0
对于给定的数据流： .filter(i-> i % 2 == 0)
.filter将所有过滤的元素放到一个Flux中，并将丢弃的元素放到另一个</e
浏览 7提问于2021-11-11得票数 1
1回答
publishOn与并行的区别
、、、、
因此，publishOn(Schedulers.parallel()创建多个线程为核心，并与这些工作人员一起在链中执行后续的operators。但是，部分指出：
您可以在任何Flux上使用并行()操作符。就其本身而言，此方法不并行工作。相反，它将工作负载划分为" rails“(默认情况下，有CPU内核的rails越多越好)。为了告诉结果的ParallelFlux在哪里执行每个轨(以及扩展到并行执行rails )，您必须使用runOn(Sch
浏览 4提问于2017-08-30得票数 3
1回答
我有下面的Flux， @Test Flux<Integer> intFlux = Flux.range(1,StepVerifier.create(intFlux).expectNext(1, 2, 3, 4, 5, 6, 7, 8, 9, 10).verifyComplete();
} 我原以为这是并行运行的，然而，它只在一个线程中执行。
浏览 39提问于2021-08-23得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
