尽管有 RxJava，但在 Android 中仍会发生 UI 阻塞

Question

我正在使用 RxJava 将网络访问转移到 Android 中的单独线程，但我的 UI 仍然阻塞。

我没有使用错误的 observable，如下所示：Android RxJava, Non Blocking?

以下代码中的代码点 [A]、[B] 和 [C] 以 [A] -> [C] -> [B] 的顺序传递，因此当前线程处理良好，RxJava 调用 [C]一旦有了结果。这很好。

此外，与在 UI 线程上进行网络调用相比，阻塞要好得多，但我仍然有轻微阻塞。调用后 UI 保持流畅，但如果服务器在几毫秒内没有响应，则会阻塞。

    private search; // search is an instance variable in the same class

    // [A]

    Observable.just(search.find("something")) // search.find calls the REST endpoint
            .subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<Search>() {

                @Override public void call(Search search) {
                    // further processing // [B]
                }

            }, new Action1<Throwable>() {

                @Override public void call(Throwable throwable) {
                    // error handler
                }

            });

    // [C]

search 是 Observable 使用它的同一个类中的一个实例变量，但端点调用是从一个单独的库执行的，这可能是一个问题吗？应该没关系吧？

我有没有做不该做的坏事？

--

Find 看起来像这样（为简洁起见，删除了异常处理）：

public Search find(String searchtext) {
    setSearchtext(searchtext);
    SearchEndpoint.find(Session.getUser().getId(), searchtext);
    return this;
}

这样的搜索端点：

public static Search find(final Long userId, final String searchtext) throws IOException {
    return ApiService.api().searches().find(userId).setFind(searchtext).execute();
}

并调用生成的 Google 云端点库。

Answer 1

我知道这已经有几个月的历史了——但您可以使用 map 运算符来运行搜索，而不是 create 一个全新的 Observable（这相对容易出错）：

String search_input = "something"; // this is where you can specify other search terms
Observable.just(search_input) 
      .map(s -> search.find(s))  // search.find calls the REST endpoint
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe( // your subscriber goes here

如果不使用 lambda，map 函数应该如下所示：

.map(new Func1<String, Search>() {
      @Override          
      public Search call(String s) {
          return search.find(s)
      }
 })

Answer 2

试试这个：

Observable.create(new Observable.OnSubscribe<Search>() {

    @Override
    // method signature is from memory - I hope I am correct...
    public void call(Subscriber<? super Search> subscriber) {
        try {
            Search search = search.find("something");
            subscriber.onNext(search);
            subscriber.onCompleted();
        } catch (SomeException e) {
            subscriber.onError(e);
        }
    }
})
// and then continue with your .subscribeOn(...)

澄清一下，也许这会使您的代码问题更加明显：

Observable.just(search.find("something"))

显然等价于

Search search = search.find("something");
Observable.just(search)

这很明显，search.find 在我们将控制权交给 rxjava 之前就已执行，它会在您当前所在的任何线程上执行 - 然后根据预先计算的值和交付构造一个 Observable的价值发生在另一个线程上，但这对你没有多大帮助......