java - RxJava just() 计算线程

Question

我很困惑。我有一个方法可以做一些长时间的工作(大约 5 秒)并返回一个 String 作为结果。我将该函数包装到一个 Observable smth 中，如下所示:

private Observable<String> getJobObservable() {
    return Observable.just(doJob());
}

但即使使用 .subscribeOn(Schedulers.computation()) 和 .observeOn(Schedulers.computation()) 我的 doJob()方法在 mainThread 上计算但是，在我将 Observable.just() 更改为 Observable.fromCallable() 之后，一切正常。为什么 Observable.just() 对线程变化没有反应？

Answer 1

如果你写

return Observable.just(doJob());

相当于

Object o = doJob();
return Observable.just(o);

现在，如果您根本没有 Observable.just(o)，那么 doJob() 在哪里执行？仅仅因为 doJob() 或 o 被放在 just 的括号之间，并不意味着 的整个执行doJob 被推迟，这与您通过 fromCallable 确保它不同。