先介绍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;
}
}
-
界面如下
avatar -
开启rxjava执行耗时后，再按显示吐司，会直接触发ANR异常，很尴尬
avatar
上正菜，加入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异常
-
运行结果
avatar
总结
- observeOn()可以多次使用来切换Observer线程
- 上面的代码就是在map转换时候切换到IO线程执行复杂且耗时操作
- 然后在Action中切换回主线程显示数据
- subscribeOn只能改变observable的线程，以最后一次调用为主
