今天继续学习RxJava，新技能get了总要记录一下。
上篇文章写到的生成观察者的两种方式其实是有区别的，例如
先看下面的代码：
private String name="lily";
private Observable<String> defObserveable;
private Observable<String> justObserveable;
private Observable<String> comObservable;
private Subscriber<String> subscriber;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
defObserveable = Observable.defer(new Func0<Observable<String>>() {
@Override
public Observable<String> call() {
return Observable.just(name);
}
});
justObserveable = Observable.just(name);
comObservable=Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext(name);
}
});
subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
PluLogUtil.log("---onNext name is " + s);
}
};
name ="lucy";
comObservable.subscribe(subscriber);
defObserveable.subscribe(subscriber);
justObserveable.subscribe(subscriber);
//打印结果：
//---_PLU LOG ---onNext name is lucy
//---_PLU LOG ---onNext name is lucy
// ---_PLU LOG ---onNext name is lily
}
可以看到just(param)方式与其他方式区别是参数是否变化。
just方式里面的参数不会随外部参数的变化而变化，但如果在其外层加了一层def的方式的话当外部参数变化的时候参数值也随一起变化，这点需要注意。而用create方式生成的Observable，要看subscribe方法的调用发生在name变量变化的前面还是后面，若在name变量值改变后调用的subscribe，因为Observer创建时OnSubscribe里面的call方法的调用是发生在subscribe调用的时候，所以name变化传入的值也会变化，如果subscribe之后再改变name的值那也不会随之变。
RxJava的运行所在线程总结：
先上代码：
Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> subscriber) {// IO 线程，由 subscribeOn() 指定
subscriber.onNext(3);
PluLogUtil.log(" -- onSubscribe call thread is "+Thread.currentThread().getName());
}
}).subscribeOn(Schedulers.io())
.subscribeOn(Schedulers.newThread())
.observeOn(Schedulers.io())
.map(new Func1<Integer, Integer>() {
@Override
public Integer call(Integer integer) {// io线程，由 observeOn() 指定
PluLogUtil.log("---map 111 thread is " + Thread.currentThread().getName());
return integer + 1;
}
})
.observeOn(Schedulers.newThread())
.observeOn(Schedulers.io())
.map(new Func1<Integer, Integer>() {
@Override
public Integer call(Integer integer) {//io线程，由 observeOn() 指定
PluLogUtil.log("----map 2 22 thread is " + Thread.currentThread().getName());
return integer + 1;
}
})
.observeOn(Schedulers.newThread())
.map(new Func1<Integer, Integer>() {
@Override
public Integer call(Integer integer) {// 新线程，由 observeOn() 指定
PluLogUtil.log("----map 333 thread is " + Thread.currentThread().getName());
return integer + 1;
}
})
.doOnSubscribe(new Action0() {//io线程，由其后的第一个subscribeOn所限定的线程决定
@Override
public void call() {
PluLogUtil.log("----doOnSubscribe thread is "+Thread.currentThread().getName());
}
}).subscribeOn(Schedulers.io()).
subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Integer integer) {//新线程，由最后一个observeOn的线程限定
PluLogUtil.log("---onNext thread is " + Thread.currentThread().getName());
}
});
/**
* 03-10 23:20:51.360 8134-8134/? D/TAG_PluginDeliverService: PluginDeliverService start com.sina.weibo.plugin.PluginDeliverService$PluginDeliverService3
---_PLU LOG ----doOnSubscribe thread is RxCachedThreadScheduler-1
---_PLU LOG -- onSubscribe call thread is RxCachedThreadScheduler-4
---_PLU LOG ---map 111 thread is RxCachedThreadScheduler-3
---_PLU LOG ----map 2 22 thread is RxCachedThreadScheduler-2
---_PLU LOG ----map 333 thread is RxNewThreadScheduler-1
---_PLU LOG ---onNext thread is RxNewThreadScheduler-1
*/
说下我自己的理解：
1.subscribeOn限定被观察者运行的线程
2.observeOn限定观察者运行的线程
3.map指令:
1>如果map前面没有observeOn&&没有subscribeOn,则该map所在的线程为主线程。
2>如果map前面只有subscribeOn则运行在scribeOn指定的线程。
3>如果map前面有observeOn（不管subscribeOn有没有）则map里代码运行在其前面的最后一个onserveOn所限定的线程上。
4.doOnSubscribe里面运行的代码所在的线程取决于其后面的第一个subscribeOn里面指定的线程的名字，请注意第一字眼和其后面的字眼。
5.subscribe的onNext:若指定了多个observeOn，则subscribe的onNext里面运行的代码使用的线程是最后一个subscribeOn限定的线程。
呼啦啦，写的跨度可能比较大，明天再继续分析，如有不对欢迎批评指正。睡啦，呼呼~~~
