rxjava怎么切换线程

在 RxJava 中，切换线程是通过 Scheduler（调度器） 来完成的，常用的操作符是：

• subscribeOn()：指定 上游（被观察者） 执行线程
• observeOn()：指定 下游（观察者 / 后续操作） 执行线程

一、常用 Scheduler（线程类型）

二、基本用法示例

1️⃣ 子线程执行任务，主线程更新 UI（Android 常见）

Observable.just("data")
    .subscribeOn(Schedulers.io())          // 在 IO 线程执行
    .observeOn(AndroidSchedulers.mainThread()) // 切回主线程
    .subscribe(data -> {
        // 更新 UI
    });

2️⃣ 多次切换线程

Observable.just(1)
    .subscribeOn(Schedulers.io())             // 上游 IO
    .observeOn(Schedulers.computation())      // 切到计算线程
    .map(i -> i + 1)
    .observeOn(AndroidSchedulers.mainThread()) // 切回主线程
    .subscribe(i -> {
        // UI 操作
    });

✅ observeOn() 可以多次调用，每次影响它之后的操作

三、subscribeOn 和 observeOn 的区别

subscribeOn()

• 决定 事件源头（如网络请求） 在哪个线程
• 只生效一次（第一个有效）

observeOn()

• 决定 之后操作符和订阅者 在哪个线程
• 可以多次切换

四、RxJava + Retrofit 示例（Android）

api.getUser()
    .subscribeOn(S Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(user -> {
        // 更新 UI
    }, throwable -> {
        // 错误处理
    });

五、注意事项

1. Android 主线程需要 RxAndroid 依赖

implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'

2. 不要在主线程做耗时操作
3. observeOn 之后才能更新 UI

如果你用的是 RxJava2 / RxJava3 或 Kotlin（RxKotlin），我也可以给你对应示例。