rxjava使用介绍2——异步操作

问题背景

在安卓日常开发和学习过程中，rxjava常用于异步操作和定时等场景，上一篇文章介绍了rxjava来进行定时操作（参考 https://blog.51cto.com/baorant24/6176404 ），本文介绍如果使用rxjava来进行异步操作。

问题分析

安卓日常开发中，进行异步操作，可以考虑的方式有多种。 1、直接通过new Thread的方式（参考 https://blog.51cto.com/baorant24/5784696 ） 2、使用handlerThread的方式（参考 https://blog.51cto.com/baorant24/5786136 ） 3、基于asyncTask的方式（参考 https://blog.51cto.com/baorant24/5786130 ） 4、线程池的方式（参考 https://blog.51cto.com/baorant24/5786154 ） 5、基于intentService的方式（参考 https://blog.51cto.com/baorant24/5787440 ）本文将介绍基于rxjava的方式。

问题解决

话不多说，直接上代码。（1）基于rxjava实现异步操作，代码如下：

    /**
     * rxjava基本使用,异步操作
     */
    private void rxjavaUse() {
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                Log.d(TAG, "subscribe: thread = " + Thread.currentThread());
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onComplete();
            }
        }).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "onSubscribe");
            }

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "accept: thread = " + Thread.currentThread());
                Log.d(TAG, "onNext: value = " + value);
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "onError: " + e.toString());
            }

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

运行结果如下：（2）基于rxjava实现线程切换的异步操作，代码如下：

    /**
     * rxjava异步操作之线程切换
     */
    private void rxjavaThread() {
        Observable.create(new ObservableOnSubscribe<Integer>() {
                    @Override
                    public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                        Log.d(TAG, "subscribe: thread = " + Thread.currentThread());
                        // 模拟耗时操作
                        Thread.sleep(3000);
                        emitter.onNext(1);
                        emitter.onComplete();
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        Log.d(TAG, "accept: thread = " + Thread.currentThread());
                    }
                });
    }

运行结果如下：