如何在Android上使用RxJava在多个线程上运行subsciber(How to run subsciber on multiple threads with RxJava on Android)

 我是RxJava的新手并且在（我猜）简单的问题上苦苦挣扎。 我想在3个线程中处理订阅部分simuleasly。 这就是我使用FixedThreadPool的原因。 示例代码： 
 
Observer.just("one", "two", "three", "four")
.observeOn(Schedulers.io())
.subscribeOn(Schedulers.from(Executors.newFixedThreadPool(3))
.subscribe(new Observer<String>() {

    public void onNext(String string) {
        Log.d(TAG, "Started: " + string);
        SystemClock.sleep(1000);
        Log.d(TAG, "Ended: " + string);
    }

    (...)

}
 
 预期结果： 
 
Started: one
Started: two
Started: three
Ended: one
Started: four
Ended: two
Ended: three
Ended: four
 
 实际结果： 
 
Started: one
Ended: one
Started: two
Ended: two
Started: three
Ended: three
Started: four
Ended: four
 
 我究竟做错了什么？ 

I am new to RxJava and struggling on a (i guess) simple problem. I want to process the subscribe part simuleasly in 3 threads. Thats why I use a FixedThreadPool. Example code:
 
Observer.just("one", "two", "three", "four")
.observeOn(Schedulers.io())
.subscribeOn(Schedulers.from(Executors.newFixedThreadPool(3))
.subscribe(new Observer<String>() {

    public void onNext(String string) {
        Log.d(TAG, "Started: " + string);
        SystemClock.sleep(1000);
        Log.d(TAG, "Ended: " + string);
    }

    (...)

}
 
Expected result:
 
Started: one
Started: two
Started: three
Ended: one
Started: four
Ended: two
Ended: three
Ended: four
 
Actual result:
 
Started: one
Ended: one
Started: two
Ended: two
Started: three
Ended: three
Started: four
Ended: four
 
What am I doing wrong?

原文：https://stackoverflow.com/questions/33268120