相关文章

• 观察者模式实例讲解
• 使用java中的类（Observable与Observer）实现观察者模式
• Rx_java2的基本使用
• Rx_java2操作符介绍1（Map、Flatmap）
• Rx_java2操作符介绍2(debounce 、filter 、switchMap )
• Rx_java2操作符介绍3（throttleFirst、debounce ）
• Retrofit结合RxJava2使用

写在前面

在Android中，执行耗时任务，需要放在子线程中去，但是不能再子线程中更新ui，通常我们使用Handler或AsyncTask去完成这些操作。
我们知道Rx_java就是为了解决异步任务而出现的，在Rxjava中，用Scheduler来进行线程控制。
Scheduler有四个方法;首先对这个四个方法作个大概讲解，最后，再通过一个Rx_java的具体实例来加深对rxjava和Scheduler的理解。

Scheduler线程控制

• Schedulers.immediate():
  直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler。
• Schedulers.newThread():
  总是启用新线程，并在新线程执行操作。
• Schedulers.io():
  I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。行为模式和 newThread() 差不多，区别在于 io() 的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中，可以避免创建不必要的线程。
• Schedulers.computation():
  计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。不要把 I/O 操作放在 computation() 中，否则 I/O 操作的等待时间会浪费 CPU。
• AndroidSchedulers.mainThread()：
  它指定的操作将在 Android 主线程运行。

实例讲解：从网络下载一张图片，并显示在ImageView中

首先，需要在build.gradle中添加以下依赖

dependencies {
    ...
    compile 'com.squareup.okhttp3:okhttp:3.7.0'
    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
    compile 'io.reactivex.rxjava2:rxjava:2.1.7'
}

添加网络请求权限

<uses-permission android:name="android.permission.INTERNET"/>

创建HttpUtils类，创建downLoadImage方法，在此方法中，创建Observable，并返回，Observable中请求网络，获取图片数据

/**
 * description: 
 * author: dujun
 * created at: 2018/1/2 11:19 
 * update: 2018/1/2
 * version: 
 */
public class HttpUtils {
    
    private OkHttpClient client;

    public HttpUtils(){
        client = new OkHttpClient();
    }

    /**
     *
     * @param path 图片路径
     * @return
     */
    public Observable<byte[]> downLoadImage(String path){
        Observable<byte[]> observable = Observable.create(new ObservableOnSubscribe<byte[]>() {
            @Override
            public void subscribe(@NonNull ObservableEmitter<byte[]> observableEmitter) throws Exception {
                // 请求网络
                Request request = new Request.Builder().url(path).build();
                Response response = client.newCall(request).execute();
                if(response.isSuccessful()){
                    byte[] bytes = response.body().bytes();
                    if(bytes != null){
                        observableEmitter.onNext(bytes);
                    }
                    observableEmitter.onComplete();
                }
            }

        });

        return observable;
    }
}

主界面下面放了一个按钮，上面放了一个ImageView，点击按钮，下载网络图片，并显示在ImageView上。
按钮的点击事件中我们绑观察者。

 button.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                httpUtils.downLoadImage(path)
                        // 绑定
                        .subscribe(new Observer<byte[]>() {
                            Disposable mD = null;
                            @Override
                            public void onSubscribe(@NonNull Disposable d) {
                                mD = d;
                            }

                            @Override
                            public void onNext(@NonNull byte[] bytes) {

                                    // 把字节流转换为bitmip，并显示在ImageView上面
                                    Bitmap bitmap = BitmapFactory.decodeByteArray(bytes, 0, bytes.length);
                                    mIv.setImageBitmap(bitmap);

                            }

                            @Override
                            public void onError(@NonNull Throwable e) {
                                Log.d(TAG,e.getMessage());
                            }

                            @Override
                            public void onComplete() {
                                Log.d(TAG,"complete");
                            }
                        });
            }
        });

现在我们点击按钮下载图片，查看log日志
异常信息为，在ui线程进行了网络请求，我们都知道，执行耗时操作都要放在子线程中，所以此时，我们需要用到线程调度器Schedulers，我们需要明白的是，我们创建的Observable和Observer都实在主线程中，现在我们需要在Observable的参数ObservableOnSubscribe的subscribe中执行耗时操作，所以，我们需要指定被观察者Observable在子线程中，所以，我们修改绑定时的代码为：

当我们点击按钮，图片并没有现在出来。当我们查看logcat

上面异常的意思就是我们在子线程更新了ui。

原因是，当我们调用了.subscribeOn(Schedulers.io())把时间注册在了子线程，因为，我们在onNext()方法中，吧下载的图片设置在了ImageView上，所以，更新ui的操作需要放在ui线程，我们调用
.observeOn(AndroidSchedulers.mainThread()指定观察者回调方法处在ui线程

再次运行项目，查看结果

图片现在显示完成。

写在后面

看完实例，在去回顾上面的Scheduler线程控制，在不同的情况下，使用不同的方法，通常用的多的是Schedulers.io():方法。线程控制就到这里，下篇将介绍Rx_java2的操作符。