RxJava 单后台线程调度器

Question

我对 RxJava 还很陌生，所以这可能是一个愚蠢的问题。我将描述我的场景。

我在 UI 线程上运行了一些代码，这些代码将更新一些图像，但这些图像不是很重要，它们在生成它们时会消耗一些资源，所以我想在单个线程上生成它们（而不是当然）并一一生成。我猜蹦床调度程序是我想要的，但我的问题是，如果我使用它，那么它会在 UI 线程上完成工作，我希望它在另一个线程上完成。

显然，我可以编写自己的线程，我可以在其中对项目进行排队，然后逐个处理这些项目，但我认为 RxJava 可能会为我提供一个简单的解决方案？

我当前的代码如下所示：

Observable<Bitmap> getImage = Observable.create(new Observable.OnSubscribe<Bitmap>() {
    @Override public void call(Subscriber<? super Bitmap> subscriber) {
        Log.w(TAG,"On ui thread? "+ UIUtils.isRunningOnUIThread());
        subscriber.onNext(doComplexTaskToGetImage());
        subscriber.onCompleted();
    }
});

getImage.subscribeOn(Schedulers.trampoline()).subscribe(new Action1<Bitmap>() {
    @Override public void call(Bitmap bitmap) {
        codeToSetTheBitmap(bitmap);
    }
});

我的日志显示“在 ui 线程上？”总是有真实的。那么，如何使该代码和所有后续尝试在单个线程（而不是 ui 线程）上按顺序运行，而无需编写一堆代码来排队该工作？

编辑：

我相信现在可以使用Schedulers.single() 来完成，或者如果您想要自己的，可以使用new SingleScheduler()。我仍在测试，但我认为它可以满足我发布此内容时的要求。

Answer 1

您正在使用trampoline 调度程序，因此这意味着您的源 observable 将在当前线程（这里是主线程）上运行。

subscribeOn 将同时适用于上游和下游。这就是为什么您的日志显示您正在 main thread

上运行

要解决此问题，您可以在subscribeOn 中使用Schedulers.single()，然后在主线程中使用observeOn。

Answer 2

在 RxJava 2 中，您可以使用 Schedulers.single()：

返回一个默认的、共享的、单线程支持的调度程序实例 需要在同一背景下强顺序执行的工作 线程。

请see the documentation了解更多详情。

我没有看到它在 RxJava 1 Schedulers documentation 中可用。

Answer 3

您可以通过以下方式之一创建一个可重用线程来为Observable 创建一个Scheduler：

• 创建一个池大小为 1 的 ThreadPoolExecuter（Executors.newSingleThreadExecutor() 是一种方便的静态工厂方法），然后使用它通过 Schedulers.from() 方法生成调度程序。
• RxAndroid 提供了一个自定义的Scheduler 实现，它使用Handler 来安排动作，因此可以与任何运行Looper 的Thread 一起使用，方法是将Handler 传递给AndroidSchedulers.handlerThread() 工厂方法。

请注意，如果您在这些任务结束时与 UI 交互，则需要在主线程 Scheduler 上进行观察。