开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

为什么switchMap(forkJoin)失败，而switchMap(arr=>forkJoin(arr))工作正常？

在云计算领域，switchMap和forkJoin是RxJS库中的两个操作符，用于处理异步操作。它们的具体功能和用法如下：

switchMap操作符：switchMap将一个Observable转换成另一个Observable，并且只返回最新的Observable的结果。当源Observable发出新的值时，switchMap会取消之前的Observable并订阅新的Observable。这个操作符常用于处理需要取消之前的请求或只关心最新请求结果的场景。
forkJoin操作符：forkJoin用于将多个Observable的结果组合成一个数组，并在所有Observable都完成时发出该数组。它会等待所有的Observable都发出值后才会发出最终的结果。这个操作符常用于并行执行多个请求，并在所有请求完成后进行处理。

现在来解答为什么switchMap(forkJoin)失败，而switchMap(arr=>forkJoin(arr))工作正常的问题。

在第一个情况下，switchMap(forkJoin)失败的原因是因为forkJoin操作符返回的是一个Observable，而switchMap操作符期望的是一个函数。由于forkJoin返回的是一个Observable，而不是一个函数，所以会导致类型不匹配的错误，从而导致失败。

而在第二个情况下，switchMap(arr=>forkJoin(arr))工作正常的原因是因为switchMap操作符接收一个函数作为参数，而不是一个Observable。在这种情况下，我们将forkJoin操作符作为一个函数传递给switchMap，这样switchMap就能正确地处理Observable的转换和订阅。

总结起来，switchMap(forkJoin)失败是因为类型不匹配，而switchMap(arr=>forkJoin(arr))工作正常是因为传递的是一个函数作为参数。

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

Angular进阶教程2-

依赖注入与HTTP的介绍 为什么使用服务？..._http.post(url, body); } 复制代码错误处理在调用接口的时候，当遇到接口请求失败或者报错的时候，前端需要做一些错误的提示信息展示，具体操作如下： this....let observer = { next: data => console.log('data'); // next表示数据正常流动， error: err=> console.log('err'...常见的运算符包含 map, filter, concat, flatmap, switchmap, forkjoin 在这里我们只调挑出forkJoin和switchMap来讲解一下，其他的操作符可以自己去查阅...// 当用户不关心接口的返回顺序 // 使用forkjoin主要是用于多个接口同时返回的时候，才会返回结果 forkJoin([ this.

4.1K3 0

调试 RxJS 第2部分: 日志篇

示例中使用 forkJoin 来组成一个发出 GitHub 用户数组的 observable 。...乍看上去没什么问题，而且大多数情况下也能正常运行。这种 bug 还是在单元测试里发现不了的。问题就是有时候 epic 就会停止运行。...解决方法是将 map 和 catch 的调用移到 switchMap 里面，就像这样: ? 这样 epic 便不会完成，它会继续 dispatch 报错的 actions: ?

1.2K4 0

ForkJoin之RecursiveAction和RecursiveTask的简单使用

ForkJoin之RecursiveAction和RecursiveTask的简单使用 Java提供的多线程可以提高CPU的利用率，现在的CPU都是多核多线程，如果不好好利用，只运行单线程程序，会使得CPU...工作窃取如上述，10位工人不可能每个人干活的速度都一样，收割有快有慢，提前结束的要去帮忙收割慢的，榨干工人资源。将一个大任务拆分给10个线程去执行，10个线程不可能同时执行完毕，肯定有快有慢。...于是就有了“工作窃取”的概念。每个线程都为分配给他的任务保存一个双向的链式队列，每完成一个任务，就会队列头上取出下一个任务开始执行。...file.getAbsolutePath()); } } } Client public class Client { public static void main(String[] args) { // 构建ForkJoin...sum); return sum; } } Client public class Client { public static void main(String[] args){ // 构建ForkJoin

2312 0

Angular快速学习笔记(4) -- Observable与RxJS

, idx) { return setTimeout(() => { observer.next(arr[idx]); if (idx === arr.length - 1) {...distinctUntilChanged , filter , take , takeUntil 转换 bufferTime , concatMap , map , mergeMap , scan , switchMap...为什么NG使用observable而不是Promise？可观察对象不会修改服务器的响应（和在承诺上串联起来的 .then() 调用一样）。...如果已发出的 AJAX 请求的结果会因为后续的修改而变得无效，那就取消它。...API 的技巧，它会在每次连续的失败之后让重试时间逐渐变长，超过最大重试次数之后就会彻底放弃。

5.2K2 0

你所不知道的Java之Switch

String都能支持,Long居然不支持，为什么没有Long？...哇，这糖为什么可以这么甜那！接着往下看看还有没有更甜的。...tableswitch : lookupswitch; 我可以概括性的说，在最大和最小case的差值不大的且label数偏多的情况下，会选择tableswitch，当差值很大而label又数不多的情况下...347337820.333 ± 4287812.567 ops/s tableSwitch 8 thrpt 200 355080497.046 ± 3393523.154 ops/s 预测失败...很明显这个方法被用来创建jump_table，而关键点就出在这个MinJumpTableSize 我们hg grep -i MinJumpTableSize 搜一下默认值 src/share/vm/opto

1.4K0 0

Lambda表达式最佳实践（2）Stream与ParallelStream

(a -> System.out.println(a)); Stream streamOfArrayPart = Arrays.stream(arr, 1, 3);//下标从零开始，startInclusive...).* ForkJoin框架是从jdk7中新特性,它同ThreadPoolExecutor一样，也实现了Executor和ExecutorService接口。...它使用了一个无限队列来保存需要执行的任务，而线程的数量则是通过构造函数传入，如果没有向构造函数中传入希望的线程数量，那么当前计算机可用的CPU数量会被设置为线程数量作为默认值。...工作窃取算法 forkjoin最核心的地方就是利用了现代硬件设备多核,在一个操作时候会有空闲的cpu,那么如何利用好这个空闲的cpu就成了提高性能的关键,而这里我们要提到的工作窃取（work-stealing...那么为什么需要使用工作窃取算法呢？

6392 0

JUC系列(七) ForkJion任务拆分与异步回调

ForkJion 什么是ForkJoin ForkJoin 下 JDK 1.7 并行执行任务的，数量越大，效率越高比如 :大数据 Map Reduce（把大任务拆分成小任务） ForkJoin 特点...: 工作窃取举例子： PS: 维护的是双端队列 Deuue A线程执行任务到第二个 B线程执行完毕，那么B线程回去讲A线程的东西拿来执行，从而提高效率认识forkjion ForkJoin...使用两个类来完成以上两件事情： ForkJoinTask：我们要使用 ForkJoin 框架，必须首先创建一个 ForkJoin 任务。...当一个工作线程的队列里暂时没有任务时，它会随机从其他工作线程的队列的尾部获取一个任务。...异步编程意味着在主线程之外创建一个独立的线程，与主线程分隔开，并在上面运行一个非阻塞的任务，然后通知主线程进展，成功或者失败。

3146 0

Fork Join 并发任务执行框架

框架: 　　就是在必要的情况下,将一个大任务,进行拆分(fork)成若干了小任务(拆到不可再拆时),再将一个个的小任务运算的结果进行join汇总 image.png Fork Join的另一大特点:工作密取...什么是工作密取? 　　...的任务执行的比较快,获得到的CPU时间片比较多,那么在他执行完毕后,就会从未执行完毕的线程的任务中的尾部,进行任务窃取,任务完成后再把结果放回去,不会造成任务竞争,因为自身执行线程的任务是从头部开始获取的,而空闲的线程是从尾部窃取的...多线程执行结果: The count is 24078313 spend time 3 The count is 24078313 spend time 3 然后我们惊奇的发现,多线程比单线程还要慢,为什么呢...每次上下文切换时间之前说过,大概花费5000-20000个时钟周期的,所以多线程执行会比单线程慢一些,所以说我们在用多线程的时候,就需要考虑线程之间的上下文切换问题,并不一定多线程就一定是好,我们只是看需求,而选择

4253 1

java中的fork join框架

workerThread - ForkJoinWorkerThread 工作线程，用来执行具体的任务。 task - ForkJoinTask 用来定义要执行的任务。...ForkJoinPool ForkJoinPool是一个ExecutorService的一个实现，它提供了对工作线程和线程池的一些便利管理方法。...ForkJoinWorkerThread ForkJoinWorkerThread是使用在ForkJoinPool的工作线程。...不同的是RecursiveAction只是用来执行任务，而RecursiveTask可以有返回值。...本文的例子可以参考https://github.com/ddean2009/learn-java-concurrency/tree/master/forkjoin

6722 0

【高并发】什么是ForkJoin？看这一篇就够了！

ForkJoin是由JDK1.7之后提供的多线程并发处理框架。ForkJoin框架的基本思想是分而治之。什么是分而治之？...相应的，ForkJoin将复杂的计算当做一个任务，而分解的多个计算则是当做一个个子任务来并行执行。...并发并发指的是在同一时刻，只有一个线程能够获取到CPU执行任务，而多个线程被快速的轮换执行，这就使得在宏观上具有多个线程同时执行的效果，并发不是真正的同时执行，并发可以使用下图表示。 ?...为什么要使用ForkJoinPool啊？ForkJoinPool是个什么鬼啊？！接下来，我们就来回答这个问题。...它使用了一个无限队列来保存需要执行的任务，而线程的数量则是通过构造函数传入，如果没有向构造函数中传入指定的线程数量，那么当前计算机可用的CPU数量会被设置为线程数量作为默认值。

1.6K2 0

LiveData beyond the ViewModel

img LiveData beyond the ViewModel 可观察范式在视图控制器和ViewModel之间工作得非常好，所以你可以用它来观察你的应用程序的其他组件，并利用生命周期意识的优势。...请注意，数据不是自动为你组合的，MediatorLiveData只是负责通知的工作。为了在我们的示例应用程序中实现转换，我们需要将两个不同的LiveDatas合并成一个。...sharedLiveDataSource.loadDataForUser("1").observe(this, Observer { // Show result on screen }) 而第二个消费者也在使用它...即使你认为你只是从一个消费者那里使用这个类，你也可能因为使用这种模式而最终出现错误。例如，当从一个Activity的一个实例导航到另一个实例时，新的实例可能会暂时收到来自前一个实例的数据。...我们不要使用MediatorLiveData，而是尝试（但失败了）用Transformation.map来解决这个问题。

1.5K3 0

Java并发编程(07)：ForkJoin框架机制详解

import java.util.concurrent.ForkJoinTask; import java.util.concurrent.RecursiveTask; public class ForkJoin01...{ this.arr = arr; this.start = start; this.over = over; } // 求和计算...right.join(); } } } 2、核心API说明 ForkJoinPool：线程池最大的特点就是分叉(fork)合并(join)模式，将一个大任务拆分成多个小任务，并行执行，再结合工作窃取算法提高整体的执行效率...工作窃取算法 ?...工作窃取算法的优点：线程间的竞争很少，充分利用线程进行并行计算，但是在任务队列里只有一个任务时，也可能会存在竞争情况。

7513 0

ForkJoin看这篇就够了！

我们来使用ForkJoin框架完成以下1-10亿求和的代码。...ForkJoin框架实现在ForkJoin框架中重要的一些接口和类如下图所示。...默认会使用Runtime.getRuntime().availableProcessors()的值 factory：创建ForkJoin工作线程的工厂，默认为defaultForkJoinWorkerThreadFactory...工作窃取算法 ForkJoinPool的各个工作线程都会维护一个各自的任务队列，减少线程之间对于任务的竞争；每个线程都会先保证将自己队列中的任务执行完，当自己的任务执行完之后，会去看其他线程的任务队列中是否有未处理完的任务...，如果有则会帮助其他线程执行；为了减少在帮助其他线程执行任务时发生竞争，会使用双端队列来存放任务，被窃取的任务只会从队列的头部获取任务，而正常处理的线程每次都是从队列的尾部获取任务。

8296 0

从Excel批量导入数据说到ForkJoin的原理

ForkJoin初识什么是ForkJoin框架 ForkJoin框架是Java7提供的一个用于并行执行任务的框架，是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架。...我们可以通过getException()方法获取异常信息，这个返回返回Throwable，如果任务被取消则返回CancellationException，如果任务正常执行完或者没有抛出异常，就返回null...框架的实现原理 ForkJoinPool由ForkJoinTask数组和ForkJoinWorkerThread数组组成，ForkJoinTask数组负责存放程序提交到ForkJoinPool的任务，而ForkJoinWorkerThread...push方法 push方法是把当前任务存放在ForkJoinTask数组的queue里，然后再调用ForkJoinPool的signalWork()方法来唤醒或者创建一个工作线程来执行任务。...= null) //调用signalWork方法来唤醒或者创建一个工作线程来执行任务 p.signalWork

1K2 0

深入浅出 RxJS 之合并数据流

数据积压问题如果某个上游 source1$ 吐出数据的速度很快，而另一个上游 source2$ 吐出数据的速度很慢，那 zip 就不得不先存储 source1$ 吐出的数据，因为 RxJS 的工作方式是..., () => console.log('completed') ); // ['c', 3, 'x'] // ['c', 3, 'y'] // complete combineLatest 工作原理...const project = (a, b) => `${a} and ${b}`; const result$ = source1$.combineLatest(source2$) .map(arr...=> project(...arr)); 多重依赖问题 combineLatest 产生的 Observable 对象数据依赖于上游的多个 Observable 对象，如果上游的多个 Observable...# forkJoin forkJoin 只有静态操作符的形式，可以接受多个 Observable 对象作为参数， forkJoin 产生的 Observable 对象也很有特点，它只会产生一个数据，因为它会等待所有参数

1.6K1 0

Vue 开发的正确姿势：响应式编程思维

为什么要牵扯到 RxJS 呢？因为它的思维对我们写好 Vue 代码很有帮助！...=> arr[1] * 5) // 一买了房，就没现金了…… const income$ = Observable.merge(salary$, rent$) const cash$ = income...为什么建议你去学习 rxjs？至少它可以帮助你写好 Vue 代码。它可以帮你写出更简洁、结构更清晰、低耦合、更容易测试的代码，这些代码更能体现原本的交互逻辑或业务流程。...useRequest 类似于 RxJS 的 switchMap，当新的发起新的请求时，应该将旧的请求抛弃。...可以的，一个比较重要的技巧就是自顶而下地去分析流程/数据流变换的过程。

3902 0

多线程之ForkJoin框架

工作窃取算法工作窃取算法：通过此算法降低线程等待和竞争。工作窃取（work-stealing）算法是指某个线程从其他队列里窃取任务来执行。那么为什么需要使用工作窃取算法呢？...而在这时它们会访问同一个队列，所以为了减少窃取任务线程和被窃取任务线程之间的竞争，通常会使用双端队列，被窃取任务线程永远从双端队列的头部拿任务执行，而窃取任务的线程永远从双端队列的尾部拿任务执行（当一个工作线程中没有任务时...，会从其他工作线程的队列尾部获取一个任务）。...Fork/Join使用两个类来完成以上两件事情： ForkJoinTask：我们要使用ForkJoin框架，必须首先创建一个ForkJoin任务。...当一个工作线程的队列里暂时没有任务时，它会随机从其他工作线程的队列的尾部获取一个任务。

3066 0

RxJS速成

而这本女性杂志肯定不是丈夫来看(如果他是正经丈夫的话), 而妻子没有直接去订阅杂志, 但是她看这本杂志有用(知道怎么去用它)....结果如下: 用现实世界中炼钢生产流程的例子来解释使用Operator来进行Reactive数据流处理的过程: 原料(矿石)整个过程中会经过很多个工作站, 这里每个工作站都可以看作是RxJS的operator...每个工作站(operator)都是可以被组合使用的, 所以可以再加几个工作站也行. 错误处理 Observable是会发生错误的, 如果错误被发送到了Observer的话, 整个流就结束了....作为Observable, 你可以去订阅它, 提供一个Observer就会正常的收到推送的值. 从Observer的角度是无法分辨出这个Observable是单播的还是一个Subject....switchMap把每个值都映射成Observable, 然后使用switch把这些内部的Observables合并成一个. switchMap有一部分很想mergeMap, 但也仅仅是一部分像而已.

4.2K18 0

ForkJoinPool：大任务拆分，让并行嗨起来！

注意，这里需要实现的是ForkJoinWorkerThreadFactory，而不是ThreadFactory....= NORMAL) reportException(s); // 正常执行结束，返回原始结果 return getRawResult(); } private int...换句话说，前两个方法是留给自己用的，而第三种方法则是为了方便别人来窃取任务用的。...任务窃取的相关过程，可以用下面这幅图来表示，这幅图建议你收藏：看到这里，不知你是否会有疑问：为什么工作线程总是从自己的头部获取任务？为什么要这样设计？...====== ForkJoin任务拆分：16383 ForkJoin计算结果：499999999500000000 ForkJoin计算耗时：143 ====== 单线程计算结果：499999999500000000

7161 0

大任务拆分，让并行嗨起来！

注意，这里需要实现的是ForkJoinWorkerThreadFactory，而不是ThreadFactory....= NORMAL) reportException(s); // 正常执行结束，返回原始结果 return getRawResult(); } private int ...换句话说，前两个方法是留给自己用的，而第三种方法则是为了方便别人来窃取任务用的。...任务窃取的相关过程，可以用下面这幅图来表示，这幅图建议你收藏：看到这里，不知你是否会有疑问：为什么工作线程总是从自己的头部获取任务？为什么要这样设计？...====== ForkJoin任务拆分：16383 ForkJoin计算结果：499999999500000000 ForkJoin计算耗时：143 ====== 单线程计算结果：499999999500000000

2541 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭