java - RxJava——单线程异步处理

标签 java asynchronous rx-java2

我有一个问题。是否可以在 RxJava 的单线程环境中异步运行两个任务?我知道 Java 应该包含此功能的库,但我认为 RxJava 不包含它。

最佳答案

当然它包含单线程异步处理,它包含任何线程计数处理。

示例

Flowable.fromCallable(() ->{
            // do something
        })
                .subscribeOn(Schedulers.single());

Schedulers.single() 的替代方案是 Schedulers.from(Executors.newFixedThreadPool(1)),您可以在其中指定线程池

关于java - RxJava——单线程异步处理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48267688/

相关文章:

java - 如何将 List<String> 写入 csv 文件并使用 supercsv 读回

javascript - 运行序列 promise 之间的区别是创建一个新的 promise 然后运行和创建所有 promise 然后运行每个 promise

android - 是否建议在订阅完成后立即调用 Disposable.dispose() ?

java - 类似的递归情况,不同的运行时间?

Java:对象为双 "hash"函数,在 [0,1) 上均匀分布

java - 如何(base64)将 protobuf 编码为字符串

c# - 在 C# 中使用 FTP 移动文件

c# - 任务、等待和 ManagementObjectCollection

android - RxJava - 在 "subscribe"lambda 中使用不同类型的变量(多个链运算符的结果)

android - 无法使用 TestSubscriber 订阅 RxJava 2 Observable