couchbase - Schedulers.io() 和 Schedulers.computation() 之间有什么区别

Question

我在 couchbase 中使用 Observables。

Schedulers.io() 和 Schedulers.computation() 之间有什么区别？

Answer 1

RxJava调度器简介。

• Schedulers.io() – 用于执行非 CPU 密集型操作，例如进行网络调用、读取光盘/文件、数据库操作等，它维护一个池线程数。

• Schedulers.newThread() – 使用此方法，每次计划任务时都会创建一个新线程。通常建议不要使用调度程序，除非有一个非常长时间运行的操作。通过newThread()创建的线程不会被重用。

• Schedulers.computation() – 该调度程序可用于执行 CPU 密集型操作，例如处理大数据、位图处理等，使用该调度程序创建的线程数量完全取决于可用的 CPU 核心数量。

• Schedulers.single() – 此调度程序将按添加的顺序执行所有任务。当需要顺序执行时可以使用此方法。

• Schedulers.immediate() – 该调度程序通过阻塞主线程以同步方式立即执行任务。

• Schedulers.trampoline() – 它以先进先出的方式执行任务。通过将后台线程数限制为1，所有的定时任务都会被一一执行。

• Schedulers.from() – 这允许我们通过限制要创建的线程数量来从执行器创建调度程序。当线程池被占用时，任务就会排队。