Android的RxJava，非阻塞？ [英] Android RxJava, Non Blocking?

问题描述

这是我的理解是，在一个单独的线程（如果提供了正确的调度程序），从而导致非阻塞操作rxjava-机器人进行操作，但一个快速和肮脏的测试，似乎证明了这是不正确的。

It was my understanding that rxjava-android performs operations on a separate thread (when provided the correct Scheduler), leading to non-blocking operations, however a quick and dirty test seems to prove this to be incorrect.

我用下面的code片段，并在两者情况下，用户界面​​是被封锁...

I used the following code snippets and in both, scenarios, the UI was being blocked...

片段1

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    int i = 0;
    while (i == 0) {}
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread());
observable.observeOn(AndroidSchedulers.mainThread());
observable.subscribe();

片段2

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    SystemClock.sleep(5000);
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread());
observable.observeOn(AndroidSchedulers.mainThread());
observable.subscribe();

我失去了一些东西呢？

Am I missing something here?

推荐答案

这个错误是，你用错了观测。正确的code应该是：

The mistake is that you use the wrong Observable. The correct code should be:

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    int i = 0;
    while (i == 0) {}
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()).subscribe();

两个 subscribeOn 和 observeOn 返回一个新的观测它实现其功能。但是原始观测不会被修改。实际上，各运营商总是会创建一个新的观测，而无需修改原来的。

Both subscribeOn and observeOn return a new Observable which implements their functions. But the original Observable is not modified. Actually, every operator will always create a new Observable without modifying the original one.

这篇关于Android的RxJava，非阻塞？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！