multithreading - RxJava 在线程方面实际上是如何在内部工作的？

Question

我有使用 RxJava 制作反应式应用程序的经验。但是，我想知道它（以及其他库，如 Spring Reactor）实际上是如何在内部工作的。我似乎无法在网上找到任何有趣的信息，只有典型的简单教程。它如何处理线程等？所有“演员”都在同一个线程上运行吗？或者它是每个“声明”的线程？

Answer 1

关于 RxJava 的一个关键点是它允许 API 所有者和使用者决定执行模型（并在不破坏任何接口的情况下更改它）。如果你想公开一个在调用订阅者线程上、在一个内部ExecutorService、在一个 Actor 上运行的 observable，这取决于你。同样，您可以使用任何适合的线程模型订阅可观察对象——无论是在调用线程上还是在某种线程池上阻塞。底线是库本身对线程模型没有意见；您需要确定最适合您所暴露的工作负载的方法。