共计 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 的线程,以最初一次调用为主
正文完