並列データベース検索のSchedulers.io（）

Question

データベーステーブルにパラレルにアクセスするときに、Schedulers.io（）またはSchedulers.newThread（）を使用する必要があるのだろうかと思います。

例えば、私がSchedulers.io（）を使用して何千ものテーブルのレコードを並行して選択すると、新しく作成されたスレッドの多くは、タスクの後のスレッドプールにあります。そのようなタスクが夜間バッチであれば

Observabe.just("table1", "table2", "table3"...) 
    .flatMap(t -> { 
     // creating the observable that emits the record 
     return Observable create(s -> { 
        Record rec = selectFrom(t); 
        s.onNext(rec); 
        s.onCompleted(); 
       }) 
       .subscribeOn(Schedulers.io()); // select in parallel 
    })... 

しかし、これらのスレッドは、それらのほとんどは、ほとんどの時間で必要とされていないので、スレッドプール内にある必要はありません。

この場合、私はSchedulers.newThread（）を使うべきだと思います。そうですか？

Answer 1

あなたが並列にIO仕事を制限したい場合は、カスタムScheduler使用：

Scheduler scheduler = Schedulers.from(Executors.newFixedThreadPool(6));