java - RxAndroid 和多线程

Question

我正在使用 RxAndroid 在后台做一些事情。这是我的代码:

Observable<MyClass[]> observable = Observable.create(new Observable.OnSubscribe<MyClass[]>() {

        @Override
        public void call(Subscriber<? super MyClass[]> subscriber) {
                System.out.println(Looper.myLooper() + " - " + Looper.getMainLooper());
                try {
                    MyObject myObject = ...
                    //do the background work
                    subscriber.onNext(myObject);
                    subscriber.onCompleted();
                } catch (Exception e) {
                    subscriber.onError(e);
                    e.printStackTrace();
                }
            }
        });

        observable.subscribeOn(Schedulers.newThread())
                  .observeOn(AndroidSchedulers.mainThread())
                  .subscribe(new Action1<MyClass[]>() {
                      @Override
                      public void call(MyClass[] myObjects) {
                          //do work on the ui Thread
                      }
                  }
        );

这是我第一次使用RxAndroid/RxJava/Looper.myLooper()/Looper.getMainLooper()

据我所知，Looper.myLooper() 为您提供当前代码正在运行的线程的名称 ID，Looper.getMainLooper() 为您提供主线程的ID。当我运行该应用程序时，在 SysOut 中，它会为它们打印出相同的 id。

我做错了什么还是我误解了2个Looper函数？

Answer 1

建议您不要使用Observable.create，除非您真的知道自己在使用 Observables 做什么。有很多事情你可能会出错。

创建中的代码在主线程上运行的原因是，它是在创建 Observable 时调用的，而不是在您订阅它时调用。

对于您想要实现的目标，我将使用 docs 中的 Observable.defer :

The Defer operator waits until an observer subscribes to it, and then it generates an Observable, typically with an Observable factory function.

代码看起来像:

Observable<MyObject> observable = Observable.defer(new Func0<Observable<MyObject>>() {
    @Override
    public Observable<MyObject> call() {

        System.out.println(Looper.myLooper() + " - " + Looper.getMainLooper());

        try {
            MyObject myObject = new MyObject();
            return Observable.just(myObject);
        }
        catch (Exception e) {
            return Observable.error(e);
        }

    }
});

Subscription s = observable
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
                new Action1<MyObject>() {
                    @Override
                    public void call(MyObject myObject) {

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

现在在你的 logcat 中你将得到:

I/System.out: null - Looper (main, tid 1) {5282c4e0}

Looper.myLooper() 函数返回 null 的原因是，当您创建新线程时，除非调用 Looper.prepare()，否则该线程不会有活套。通常，线程上不需要循环程序，除非您无论如何都想向其发送 Runnable。