关于rxjava的小白问题
Observable.just("a", "b", "c", "d")
.map(s -> s + "---" + Thread.currentThread().getName())
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.trampoline())
.subscribe(s -> System.out.println(s + "----" + Thread.currentThread().getName()));
如上是rxjava的helloworld,我可以在项目的各个地方任意使用下面的代码吗?rxjava会使用一个线程池吧,不会我写一个就创建一个吧,当并发非常大的时候这个地方是不是要优化了?
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.trampoline())
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论