fork-join 相关问题

Fork-Join意味着将工作拆分为片段并将结果连接在一起。您可以将工作拆分为组件,并将每个组件安排到一个线程池,在所有组件完成时加入结果。您可以递归地将聚合结构分解为相同的任务,并在所有任务完成后加入结果。

使用 ForkJoin 实现 Stackoverflow 和 Quicksort Java 实现

我一直在尝试使用Java中的ForkJoin进行快速排序,而在大部分情况下,当数组的每个元素相等时,我会得到一个堆栈溢出。 导入 java.util.Comparator; 导入j...

回答 1 投票 0

Spring 状态机 JOIN 的意外行为

我正在测试Spring状态机(版本4.0.0)的一些功能。当我遇到 fork/join 功能时,JOIN 的行为对我来说有点奇怪(FORK 按我的预期工作)。有什么解释吗

回答 1 投票 0

FORKJOIN 发生错误后不会停止后续请求

问题在于,即使前一个查询失败,forkjoin 数组中的查询也会继续执行。例如,在第一个请求 putCategory$ 中已经发生错误(名称已经 exi...

回答 1 投票 0

从forkJoin获取数据后才订阅Subject

我想将一些数据从一个模块传递到另一个模块。为此,我正在使用主题。我创建了以下主题: 从 '@angular/core' 导入 { Injectable } ; 从“rxjs”导入{主题}; @

回答 1 投票 0

等待多个请求完成的正确方法是什么?

我有一个组件需要多个 get 请求才能返回我需要的所有数据。这些是彼此独立的,但我想将所有调用放在一起并在此之后加载 UI ...

回答 3 投票 0

我可以使用“wait fork”来等待任务内生成的线程吗?

我正在尝试系统verilog线程,并且编写了以下运行良好的示例。 目标只是生成 2 个打印数字的任务,并使用“wait f...

回答 1 投票 0

RxJS 将数组映射到可观察对象并返回到数组中的普通对象

我有一个对象数组,我需要将每个对象分别传递到异步方法中(后面的过程使用 Promise 处理,然后通过 Observable.fromPromis 转换回 Observable...

回答 1 投票 0

解释为什么当 #10 begin A = 1'b0; 时 fork-join 的行为不同B = 1'b1;结束,并到#10;开始 A = 1'b0; B = 1'b1;结束

请注意第二种情况下#10延迟后的分号。 我以为我理解了 fork-join,但是在这些输出之后,我认为我不理解。有人可以解释一下为什么分号是原因......

回答 1 投票 0

解释为什么当 #10 begin A = 1'b0; 时 fork-join 的行为不同B = 1'b1;结束,并到#10;开始 A = 1'b0; B = 1'b1;结束

请注意第二种情况下#10延迟后的分号。 我以为我理解了 fork-join,但是在这些输出之后,我认为我不理解。有人可以解释一下为什么分号是原因......

回答 1 投票 0

Java ForkJoinPool 的并行度是多少?

我正在研究有关 Fork/Join 框架的 oracle 文档,当时我遇到了 ForkJoinPool 的构造函数:ForkJoinPool(intparallelism)。文档说这是并行级别,

回答 2 投票 0

java 使用parallelStream 生成map

我有一个单线程代码如下: 私人地图 empToEmpDept(List empList) { 地图地图=新的HashMap<&g...

回答 1 投票 0

Rxjs的combineLatest确实返回了订阅中的可观察值

在我需要根据 userid 进行呼叫后,我尝试获取 Userid 和 serviceId,这里的 serviceId 问题是它没有将可观察值返回到 ts。 服务.ts 函数 getData():observabl...

回答 2 投票 0

在 SystemVerilog 中 fork join_none 后仅等待一些线程完成

在 SystemVerilog 中,我需要等待一些在 fork join_none 结构中执行的线程完成。但是在另一个 fork join_none 结构中还有另一个进程会 ...

回答 2 投票 0

Fork join spyon in jasmine angular

你能指导我如何模拟 Angular 茉莉花测试用例中的 fork join 函数吗? 测试(){ 分叉连接( this.httpservice.postData('url1')。 ,json.strigfy(this.json)), 这个.httpservice.postDa ...

回答 0 投票 0

如何在角度应用程序中组合 2 个 Observable

我有一个问题,如何在复杂的情况下组合 2 个可观察对象。我给你看代码如下: 所以我有 2 个 Observable: 1:this.loadingState:可观察 2:currentData:可观察 所以加载...

回答 0 投票 0

forkJoin 或 rxjs 的 combineLatest 不调用 api 服务

我正在尝试在 forkJoin 或 combineLatest 中传递 api 调用,然后通过管道传输它们,最后将结果一一映射,以将它们的值分配给类级变量。 所有的 api 调用都返回一个

回答 1 投票 0

rxjs连接观测值

This.filterValues$[filterName]= concat(of(this.initialValues), / ['1', '2', '3'] this.getFilterValues(filterName, this.afterKey) / ['4', ...]。

回答 1 投票 0

嘲笑forkJoin的Angular单元测试

我正在Angular 9中使用Jest & Spectator工作,并试图为一个组件编写单元测试。问题是,在我的ngOnInit()中,我有一个forkJoin对我的门面进行了一些调用,然后,在...

回答 1 投票 0

什么时候应该在ForkJoinTask.invokeAll()之后调用join()

API说:"方法invokeAll(在多个版本中可用)执行最常见的并行调用形式:分叉一组任务并将它们全部加入。" 所以我的假设是,如果我使用......

回答 1 投票 0

使用合并Map和管道的Forkjoin,使用api请求的返回结果。

我想使用多个api请求的返回结果,并将其作为第二个api请求的参数,而第二个api请求返回的结果我必须在第三个api请求中重用。

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.