今天继续学习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>>() {@Overridepublic Observable<String> call() {return Observable.just(name);}});justObserveable = Observable.just(name);comObservable=Observable.create(new Observable.OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext(name);}});subscriber = new Subscriber<String>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic 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>() {@Overridepublic 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>() {@Overridepublic 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>() {@Overridepublic 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>() {@Overridepublic Integer call(Integer integer) {// 新线程，由 observeOn() 指定PluLogUtil.log("----map 333 thread is " + Thread.currentThread().getName());return integer + 1;}}).doOnSubscribe(new Action0() {//io线程，由其后的第一个subscribeOn所限定的线程决定@Overridepublic void call() {PluLogUtil.log("----doOnSubscribe thread is "+Thread.currentThread().getName());}}).subscribeOn(Schedulers.io()).subscribe(new Subscriber<Integer>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) {}@Overridepublic 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限定的线程。
呼啦啦，写的跨度可能比较大，明天再继续分析，如有不对欢迎批评指正。睡啦，呼呼~~~