Rxjava如何创建线程并将文本返回到UI

Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        // 在这里执行耗时操作，如网络请求或数据库查询
        String result = performLongRunningTask();
        emitter.onNext(result); // 发射结果到观察者
        emitter.onComplete(); // 完成任务
    }
})
.subscribeOn(Schedulers.io()) // 指定在 IO 线程执行任务
.observeOn(AndroidSchedulers.mainThread()) // 指定在主线程回调结果
.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(String result) {
        // 处理结果并更新 UI
        updateUI(result);
    }

    @Override
    public void onError(Throwable e) {
        // 处理错误
    }

    @Override
    public void onComplete() {
        // 任务完成的操作
    }
});

Observable.just(performLongRunningTask())
    .subscribeOn(Schedulers.io()) // 指定在 IO 线程执行任务
    .observeOn(AndroidSchedulers.mainThread()) // 指定在主线程回调结果
    .subscribe(new Observer<String>() {
        // ...
    });