Observable 在主线程上运行，即使在另一个线程上调用 subscribeOn()

Question

我在我的一项活动中遇到了一个奇怪的问题。从拍摄照片/视频回来时，在我的 onActivityResult 中，我会显示一个对话框，让用户为相机命名。用户按下“确定”后，我将 onNext() 发送给具有复制文件（并显示进度对话框）的请求文件名的主题。

出于某种原因，执行复制的 map() 函数总是在主线程上调用，即使我调用 subscribeOn(Schedulers.io()).

@Override
protected void onActivityResult(final int requestCode, int resultCode, Intent intent) {
    ...

    final PublishSubject<String> subject = PublishSubject.create();`

    mSubscription = subject
            .subscribeOn(Schedulers.io())
            .map(new Func1<String, String>() {
                @Override
                public String call(String fileName) {
                    Log.I.d(TAG,"map");
                    return doSomeIOHeavyFuncition();
                }
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<String>() {
                @Override
                public void call(final String fullPath) {
                    Log.d(TAG,"onNext");
                    doSomethingOnUI(fullPath);

                    subject.onCompleted();
                }
            }, new Action1<Throwable>() {
                @Override
                public void call(Throwable throwable) {
                    ...
                }
            }, new Action0() {
                @Override
                public void call() {
                    ...
                }
            });

    final AlertDialog dialog = new AlertDialog.Builder
    ....
    .create()
            .show();

    dialog.getButton(DialogInterface.BUTTON_POSITIVE)
            .setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View view) {
                    String someString = getStringFromDialog(dialog);

                    dialog.dismiss();
                    InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
                    imm.hideSoftInputFromWindow(input.getWindowToken(), 0);

                    showProgressDialog();
                    subject.onNext(someString);
                }
            });
}

将 subscribeOn(Schedulers.io()) 调用更改为 observeOn(Schedulers.io()) 解决了问题。我还是想知道为什么它不起作用...

Answer 1

subscribeOn 和 observeOn 是最容易混淆的运算符。前者确保订阅副作用发生在指定的调度程序（线程）上，但这并不意味着值也会在该线程上弹出。

例如，如果您的 Observer 在有人订阅时打开网络连接，您不希望在主线程上运行，因此，您需要 subscribeOn 指定订阅的位置，从而将创建网络连接。

当数据最终到达时，发出线程可以是任何东西，调度程序之一或后台普通旧线程。由于我们不知道或者不喜欢那个线程，所以我们想把数据的观察移到另一个线程。这就是 observeOn 所做的：确保它之后的操作符将在指定的调度程序上执行它们的 onNext 逻辑。 Android 开发人员已经使用它来将值的观察移回主线程。

但很少有人解释的是，当您希望在最终结果再次到达主线程之前从主线程进行一些额外的计算时会发生什么：使用多个 observeOn 运算符：

source
.observeOn(Schedulers.computation())
.map(v -> heavyCalculation(v))
.observeOn(Schedulers.io())
.doOnNext(v -> { saveToDB(v); })
.observeOn(AndroidSchedulers.mainThread())
...

Observable 在主线程上运行，即使在另一个线程上调用 subscribeOn()

Observable runs on main thread even though subscribeOn() is called on another thread

java

android

rx-java

rx-android