fork-join 相关问题

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

如何链接mergeMap来获取相关对象

我在链接 mergeMap 来检索相关对象时遇到问题。首先,我得到用户列表 userService.loadUsers$().pipe( mergeMap((用户:User[]) => forkJoin(users.map((用户:IUser) =...

回答 1 投票 0

API完成后forkJoin - rxjs

所以,我在这里有点修复。我有 2 个 GET API。一旦这些 API 返回成功,我就需要做一些事情。 我做了以下事情。 让 sub1$ = this.myService.callFirstApi(); 让 sub2$ = this.myService.

回答 1 投票 0

Rxjs forkJoin 运算符不会发出任何内容

我在使用 forkjoin 时遇到问题。 我有三个 Angular 服务负责进行 http 调用。 在每个服务中都有一个 Observable,当 tttp 请求收到响应时,

回答 1 投票 0

为什么parallelStream不使用全部可用的并行性?

我创建了一个并行度为 25 的自定义 ForkJoinPool。 CustomForkJoinPool = new ForkJoinPool(25); 我有一个包含 700 个文件名的列表,我使用这样的代码从

回答 3 投票 0

强制对可观察值进行嵌套循环以等待所有

我读了很多关于forkJoin,async,await,..但最终没有找到解决方案。 组件 A 具有组件 B 的列表。组件 B 可能包含组件 C 的列表,也可能不包含。 组件 C 可能包括...

回答 1 投票 0

使用 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

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