RxJava観測可能パラレルかどうか

これは、このコードは、ちょうどなしの平方を計算コード

public void d(){ 
     long startTime = System.currentTimeMillis(); 
     Observable.range(1, 1000000).map(c -> c*c).subscribe(); 
     long endTime = System.currentTimeMillis(); 
     System.out.println(endTime - startTime); 
    }

です。並行しているのですか？

つまり、1,2,3などを順番に反復して正方形を計算しているのか、並列処理を使用しているのでしょうか？

出典

2017-10-25 Ankit Bansal

観測対象は性質上連続しており、並列になるとフローを分割する必要があります。最初にRxJavaに関するチュートリアルを読んでみてください。 – akarnokd

あなたは良いチュートリアルコードの賢明なリンクを提供できます –

https://stackoverflow.com/questions/35425832/rxjava-and-parallel-execution-of-observer-code – akarnokd

質問を投稿する前に、公式のドキュメントから常にドキュメントを読むことをお勧めします。

RxJava-Operatorsページから始めて、あなたの目的に合った演算子を選択するツリーが含まれていることをお勧めします。

質問に戻ると、並行性と並列化を理解するために、RxJava-Schedulersページを確認してください。

出典

2018-01-16 07:57:25 unlucy7735

RxJava観測可能パラレルかどうか

答えて

関連する問題