先介绍Scheduler概念

  • 官网文档

  • 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);             }         });
  • 这次再运行RxJava后，点击吐司按钮也能够相应
  • 而且不会触发ANR异样
  • 运行后果

总结

  • observeOn()能够屡次应用来切换Observer线程
  • 下面的代码就是在map转换时候切换到IO线程执行简单且耗时操作
  • 而后在Action中切换回主线程显示数据
  • subscribeOn只能扭转observable的线程，以最初一次调用为主