rxjava-schedulers vs executorservice？

Question

我预感到，对于RxJava中计算量高、并行化的任务，传统的executorservice会比scheduler快。

我认为这个密码

Observable<MyItem> source = ...

source.flatMap(myItem -> myItem.process().subscribeOn(Schedulers.computation()))
.subscribe();

我会跑得比这慢

final ExecutorService svc = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1);
Observable<MyItem> source = ...

source.flatMap(myItem -> myItem.process().subscribeOn(Schedulers.from(svc)))
.finallyDo(svc::shutdown)
.subscribe();

我将这两种方法与我在工作中所做的一个典型的并行过程进行了比较，我得到了以下结果。

EXECUTOR

START: 2016-01-25T09:47:04.350
END: 2016-01-25T09:48:37.181
TOTAL TIME (SEC): 92


COMPUTATION SCHEDULER

START: 2016-01-25T09:50:37.799
END: 2016-01-25T09:54:23.674
TOTAL TIME (SEC): 225

Answer 1

我做了几个测试，发现创建自己的executorservice实际上可以提高并行化性能。我在这里写了一篇关于它的博客文章。