在 0.18 中，如何在调度程序上执行后台任务？答案

【问题标题】：in 0.18, how do background tasks get executed on a scheduler?在 0.18 中，如何在调度程序上执行后台任务？
【发布时间】：2017-02-15 03:45:42
【问题描述】：

感觉好像我在这里遗漏了一些东西，但是我曾经做的地方：

    Schedulers.io().schedule(new Action1<Scheduler.Inner>() {
      @Override
      public void call(Scheduler.Inner inner) {
        doWhatever();
      }
    });

我似乎不能再简单地使用调度程序来运行后台任务，而无需管理取消订阅（https://github.com/Netflix/RxJava/wiki/Scheduler 和 https://github.com/Netflix/RxJava/blob/master/rxjava-core/src/main/java/rx/Scheduler.java）。

是否有 0.18 的模式可以让我轻松运行 doWhatever，而无需跟踪工作人员、取消订阅等？

看来你可以做到：

final Worker worker = Schedulers.io().createWorker();
worker.schedule(new Action0() {
  @Override
  public void call() {
    doWhatever();
    worker.unsubscribe();
  }
});

但这似乎需要更多的工作，（尤其是对于 android.mainThread 调度程序）。

我在这里错过了什么？

【问题讨论】：

这里是讨论：github.com/Netflix/RxJava/issues/997
我已经通读了那个讨论 - 我不确定你到底指的是什么，但我没有看到任何在那里给出的例子来解决这个问题中表达的观点.你想在这里具体说什么？

标签： rx-java

【解决方案1】：

将调度程序与 Observable 结合使用

如果您使用 RxJava，我认为您应该让 Observables 处理调度程序。在我的代码中，我认为我不必创建自己的工人并管理它。

将 Observable 与 Scheduler 一起使用并在两种线程类型之间切换的示例。

public void doSomething() {
    Observable
            .create(new Observable.OnSubscribe<Boolean>() {
                @Override
                public void call(Subscriber<? super Void> subscriber) {
                    int sleepTime = (int) (Math.random() * 10000);

                    System.out.println("Running on: " + Thread.currentThread().getId() + " sleep: " + sleepTime);

                    try {
                        Thread.sleep(sleepTime);
                    } catch (InterruptedException e) {
                        System.out.println("Error!!! " + Thread.currentThread().getId());
                        subscriber.onError(e);
                        return;
                    }

                    System.out.println("Done!!! " + Thread.currentThread().getId());
                    subscriber.onNext(true);
                    subscriber.onCompleted();
                }
            })
            // this will schedule your work in a background io thread. In this example the "call" method above.
            .subscribeOn(Schedulers.io())
            // this will schedule your next/complete/error on the androids main thread.
            .observeOn(AndroidSchedulers.mainThread())
            // kick off the actual work.
            .subscribe(new Subscriber<Boolean>() {
                @Override
                public void onCompleted() {
                    // runs in main thread.
                }

                @Override
                public void onError(Throwable e) {
                    // runs in main thread.
                }

                @Override
                public void onNext(Boolean result) {
                    // runs in main thread.
                }
            });
}

直接使用调度器

不过，我明白在某些情况下可能需要您直接使用调度程序。所以，如果你想直接使用调度器。我认为以下内容符合您的要求。

使用 runAction 创建调度程序实用程序。

public static void runAction(Action0 action, Scheduler scheduler) {
    Scheduler.Worker worker = scheduler.createWorker();
    worker.schedule(new Action0() {
        @Override
        public void call() {
            action.call();
            worker.unsubscribe();
        }
    });
}

然后要使用它，传递要执行的操作和要使用的调度程序。

SchedulerUtil.runAction(new Action0() {
    @Override
    public void call() {
        int sleepTime = (int) (Math.random() * 10000);

        System.out.println("Running on: " + Thread.currentThread().getId() + " sleep: " + sleepTime);
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException ignored) {
        }

        System.out.println("Done!!! " + Thread.currentThread().getId());
    }
}, Schedulers.io());

【讨论】：