RxJava 1.x 理解-2

给RxJava 加入线程控制 --Scheduler

在RxJava 1.x 理解-1中，我们说到了RxJava的简单用法，但是这还远远不够，因为这简单用法是在同一个线程中使用的。比如我们需要在子线程中进行耗时操作，在Android 主线程中进行UI操作，这样才不会导致卡顿的发生。

先上代码：

        Observable
                .create(new Observable.OnSubscribe<String>() {
                    @Override
                    public void call(Subscriber<? super String> subscriber) {
                        subscriber.onNext("提供数据01 获取线程id:" + Thread.currentThread().getId());
                        subscriber.onNext("提供数据02 获取线程id:" + Thread.currentThread().getId());
                        subscriber.onNext("提供数据03 获取线程id:" + Thread.currentThread().getId());
                        subscriber.onNext("提供数据04 获取线程id:" + Thread.currentThread().getId());
                    }
                })
                .subscribeOn(Schedulers.io())              // 订阅发生在   // 指定 subscribe() 发生在 IO 线程   
                .observeOn(AndroidSchedulers.mainThread()) // 观察发生在   // 指定 Subscriber 的回调发生在主线程 
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        Log.d(TAG, "Item: " + s + " 执行调用 获取线程id:" + Thread.currentThread().getId());
                    }
                });

给RxJava 加入线程控制 --Scheduler

更多相关文章

随机推荐