RxJava操做符observeOn的并发问题

RxJava操做符observeOn的并发问题 前几天同事丢给我一段RxJava的代码,代码想要经过observeOn指定线程池来实现多线程消费,这个想法自己很美好。实际却没有发现多线程消费的现象,因此我决定好好研究一番,就以?的代码开始吧!web long sleepTime = 300; long emitFrequency = 100; Observable.interval(emitFr
相关文章
相关标签/搜索