Android RxJava：如何实现新线程执行函数并在UI线程展示结果？

嘿，你这段代码已经抓住了RxJava线程切换的核心逻辑啦！不过getKKMInfo()还没实现，我来帮你补全完整的可运行代码，顺便给你提几个关键注意点：

完整Fragment实现代码 #

import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers
import io.reactivex.rxjava3.core.Single
import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.schedulers.Schedulers
import android.os.Bundle
import android.util.Log
import android.view.LayoutInflater
import android.view.View
import android.view.ViewGroup
import android.widget.Toast
import androidx.fragment.app.Fragment

class FragmentKKMInfo : Fragment() {
    // 持有Disposable，用于在生命周期结束时取消订阅，避免内存泄漏
    private var infoDisposable: Disposable? = null

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        
        infoDisposable = getKKMInfo()
            .subscribeOn(Schedulers.io()) // 指定后台IO线程执行任务
            .observeOn(AndroidSchedulers.mainThread()) // 指定主线程处理回调、更新UI
            .subscribe({ info -> 
                Log.i("RX", "LOG3") 
                // 这里放心写UI更新逻辑，已经在主线程了
                updateUIWithKKMInfo(info)
            }, { error -> 
                Toast.makeText(context, error?.message ?: "获取数据失败", Toast.LENGTH_LONG).show() 
                Log.e("RX", "获取KKM信息出错", error)
            })
        
        Log.i("RX", "LOG1")
    }

    // 补全getKKMInfo方法：返回Single<KKMInfo>，模拟后台获取数据的逻辑
    private fun getKKMInfo(): Single<KKMInfo> {
        return Single.create { emitter ->
            try {
                // 模拟后台耗时操作：比如从数据库/网络接口获取数据
                Thread.sleep(1000)
                val kkmInfo = KKMInfo(
                    deviceId = "KKM-2024-001",
                    status = "正常",
                    lastSyncTime = "2024-05-20 14:30"
                )
                emitter.onSuccess(kkmInfo)
            } catch (e: Exception) {
                emitter.onError(e)
            }
        }
    }

    // 示例UI更新方法
    private fun updateUIWithKKMInfo(info: KKMInfo) {
        // 这里可以操作TextView、Button等UI控件，比如：
        // tvDeviceId.text = info.deviceId
        // tvStatus.text = info.status
    }

    // 定义KKMInfo数据类，用于承载返回结果
    data class KKMInfo(
        val deviceId: String,
        val status: String,
        val lastSyncTime: String
    )

    override fun onDestroyView() {
        super.onDestroyView()
        // 取消订阅，避免内存泄漏
        infoDisposable?.dispose()
    }
}

几个关键细节提醒 #

• 线程切换逻辑：subscribeOn只需要调用一次，它决定了Observable上游任务的执行线程；observeOn可以多次调用，用来切换不同的线程处理下游逻辑
• 内存泄漏防护：一定要在Fragment的onDestroyView或者onDestroy方法中取消Disposable订阅，不然Fragment销毁后Observable还在执行，会持有Fragment引用导致内存泄漏
• 数据类型选择：因为是获取单个数据结果，用Single比Observable更合适，语义更清晰
• 错误处理：在错误回调里记得打印异常栈信息，方便排查问题，同时给用户友好的提示

内容的提问来源于stack exchange，提问作者GuessWho