gpt4 book ai didi

java - 如何使用 RxJava2 将不同的异步源聚合为一个?

转载 作者:行者123 更新时间:2023-11-30 02:19:54 26 4
gpt4 key购买 nike

假设我有这个同步方法:

public FruitBowl getFruitBowl() {
Apple apple = getApple(); // IO intensive
Banana banana = getBanana(); // CPU intensive
return new FruitBowl(apple, banana);
}

我可以使用 Java 并发 API 将其转换为异步方法,结果有点像这样:

public Future<FruitBowl> getFruitBowl() {
Future<Apple> appleFuture = getAppleAsync(); // IO intensive
Future<Banana> bananaFuture = getBananaAsync(); // CPU intensive
return createFruitBowlAsync(appleFuture, bananaFuture); // Awaits appleFuture and bananaFuture and then returns a new FruitBowl
}

在利用调度程序(io 和计算)并返回 Single 的同时,惯用的 Rx 方式是什么?

最佳答案

您可以使用zip运算符(operator)。并为每个异步操作定义一个不同的线程。如果不这样做,这些方法将在同一线程上依次执行。

我会创建一个Observable两种方法的版本,以便分别返回 Observable<Apple>Observable<Banana>并以这种方式使用它们:

Observalbe.zip(getAppleObservable().subscribeOn(Schedulers.newThread()), 
getBananaObservable().subscribeOn(Schedulers.newThread()),
(apple, banana) -> new FruitBowl(apple, banana)))
.subscribe(/* do your work here with FruitBowl object */);

Here有关如何使用 zip 并行化操作的更多详细信息运算符

关于java - 如何使用 RxJava2 将不同的异步源聚合为一个?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47177248/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com