android - 带有 RxJava2 的 Firebase.jobdispatcher 不能异步工作

Question

我正在尝试使用 RxJava2 异步启动 Firebase jobdispatcher。

@Override
    public boolean onStartJob(JobParameters job) {
    Completable.fromAction(new Action() {
            @Override
            public void run() throws Exception {
                startMethod();
            }
        }).subscribeOn(mSchedulerProvider.io())
          .observeOn(mSchedulerProvider.mainThread())
          .subscribeWith(new DisposableCompletableObserver() {
            @Override
            public void onComplete() {
                LOG.debug("onComplete");
                onStopJob(job);
            }

            @Override
            public void onError(Throwable e) {

            }
        });
        return true;
}

@Override
    public boolean onStopJob(JobParameters job) {
        LOG.debug("stop job");
        return true;
}

当我添加 subscribeOn(mSchedulerProvider.io()) 行时 startMethod() 不会启动，如果我删除此行 startMethod() 从主线程开始。

Answer 1

我认为您的问题可能出在observeOn 语句中。我尝试复制您拥有的代码。但由于我假设您没有尝试更新 UI 线程，删除 observeOn 将允许进程在 RxCachedScheduler 线程上完成，Schedulers.io( ) 创建并且不会阻塞 UI

Completable.fromAction(new Action() {
        @Override
        public void run() throws Exception {
            Log.e("RXJAVA","Running on | " + Thread.currentThread().getName());
            startMethod();
        }
    })
    .subscribeOn(Schedulers.io())
   // .observeOn(AndroidSchedulers.mainThread()) //Try comment this out
    //also try subscribe instead of subscribeWith
    .subscribe(new DisposableCompletableObserver() {
        @Override
        public void onComplete() {
            System.err.println("RXJAVA onComplete | " + Thread.currentThread().getName());
            Log.e("RXJAVA","onComplete | " + Thread.currentThread().getName());
        }

        @Override
        public void onError(Throwable e) {

        }
    });