RxJava2 多线程
前言
subscribeOn指定Observable自身在哪个调度器上执行observeOn指定一个观察者在哪个调度器上观察这个Observable
subscribeOn这个操作符指定的是Observable自身在哪个调度器上执行，而且跟调用的位置没有关系。
而observableOn则是指定一个观察者在哪个调度器上观察这个Observable
多次调用
- 如果多次调用
subscribeOn只有第一次调用subscribeOn时选择的调度器.subscribeOn(Schedulers.newThread())有作用，而后来选择的都没有作用。 - 当每次调用了
observableOn这个操作符时，之后都会在选择的调度器上进行观察，直到再次调用observableOn切换了调度器。
这说明了subscribeOn这个操作符，与调用的位置无关，而且只有第一次调用时会指定Observable自己在哪个调度器执行。
其实有一种情况特殊，就是在doOnSubscribe操作符之后调用，可以使doOnSubscribe在指定的调度器中执行。
比如如下代码
Observable<String> obs = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
System.out.println("Observable:" + Thread.currentThread().getId());
emitter.onNext("数据");
emitter.onComplete();
}
});
obs
.subscribeOn(Schedulers.io())
.map(new Function<String, String>() {
@Override
public String apply(String o) throws Exception {
System.out.println("map01:" + Thread.currentThread().getId());
return o;
}
})
.observeOn(Schedulers.io())
.map(new Function<String, String>() {
@Override
public String apply(String o) throws Exception {
System.out.println("map02:" + Thread.currentThread().getId());
return o;
}
})
.observeOn(Schedulers.newThread())
.map(new Function<String, String>() {
@Override
public String apply(String o) throws Exception {
System.out.println("map03:" + Thread.currentThread().getId());
return o;
}
})
.observeOn(Schedulers.newThread())
.subscribe(new Consumer<String>() {
@Override
public void accept(String o) throws Exception {
System.out.println("subscribe:" + Thread.currentThread().getId());
}
});会打印
Observable:12
map01:12
map02:13
map03:14
subscribe:15- 如果不指定
subscribeOn那么会在当前所在线程中操作 - 只要不调用
observeOn那么后续的操作一直会在之前的线程中操作 - 多次调用
subscribeOn(Schedulers.io())会在不同的线程中操作
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2018-08-23，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录