关于android:Android进阶学习RxJava五线程调度者Scheduler

3次阅读

共计 2502 个字符，预计需要花费 7 分钟才能阅读完成。

官网文档
If you want to introduce multithreading into your cascade of Observable operators, you can do so by instructing those operators (or particular Observables) to operate on particular Schedulers.
- 如果要将多线程引入可察看运算符的级联中，能够通过批示那些运算符（或特定的可察看变量）在特定的调度程序上进行操作来实现 (百度翻译)
集体了解: 主线程到子线程之间的切换器
重点: 线程切换

为什么要切换线程

RxJava 默认工作在以后线程内
- 默认的个别是主线程
主线程负责 UI 的刷新，如果 RxJava 产生阻塞，UI 会卡死，呈现 ANR 异样 * 耗时操作与网络申请，必须切换到子线程工作

先来小试牛刀一下

前文中降到了 map 操作，假如 map 为耗时操作 (应用延时)
在界面上放一个按钮，点击能够显示吐司
在执行耗时操作时候，点击按钮查看是否有响应

先来不加调度器写法，看看成果

万一不加调度器也好用，还瞎折腾啥

/******************* 线程调度者 Scheduler ********************/
public void test_6() {Observable.just("abc", "cba")
            .map(new Func1<String, String>() {
                @Override
                public String call(String s) {
                    try {
                        // 手动延时 10 秒钟，模仿耗时操作
                        Thread.sleep(10000);
                    } catch (InterruptedException e) {e.printStackTrace();
                    }
                    return s;
                }
            })
            .subscribe(new Action1<String>() {
                @Override
                public void call(String s) {LogUtils.e(s);
                }
            });
}
/********** 单击事件 *********/
@OnClick({R.id.show_toast, R.id.open_rxjava})
public void onViewClicked(View view) {switch (view.getId()) {
        case R.id.show_toast:
            ToastUtil.showLong(Test3Activity.this, "Hello World");
            break;
        case R.id.open_rxjava:
            test_6();
            break;
        default:
            break;
    }
}

界面如下

开启 rxjava 执行耗时后，再按显示吐司，会间接触发 ANR 异样，很难堪

上正菜，退出 Scheduler 调度线程

次要用到两个函数
subscribeOn() 扭转 observable 的线程，多个以最初一个为准
- observeOn() 用于 Observer，扭转调用它之后代码的线程，多个都失效
  - 有以下几种应用办法

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 主线程运行

耗时操作放到子线程中，打印 Log 返回到主线程
别离在办法中打印线程名称

 Observable.just("abc", "cba")
         .subscribeOn(AndroidSchedulers.mainThread())
         .observeOn(Schedulers.io())
         .map(new Func1<String, String>() {
             @Override
             public String call(String s) {Thread thread = Thread.currentThread();
                 LogUtils.e("Func1_map:"+ thread.getId()+"Name:"+ thread.getName());
                 try {
                     // 手动延时 10 秒钟，模仿耗时操作
                     LogUtils.e("我是耗时操作");
                     Thread.sleep(10000);
                 } catch (Exception e) {e.printStackTrace();
                 }
                 return s;
             }
         })
         .observeOn(AndroidSchedulers.mainThread())
         .subscribe(new Action1<String>() {
             @Override
             public void call(String s) {Thread thread = Thread.currentThread();
                 LogUtils.e("Action1:"+ thread.getId()+"Name:"+ thread.getName());
                 LogUtils.e(s);
             }
         });