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

41次阅读

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

先介绍 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 的线程,以最初一次调用为主

正文完
 0