关于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())
阅读 1.8k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进