Schedulers.io() auf parallele Datenbanksuche

Question

Ich frage mich, ob ich Schedulers.io() oder Schedulers.newThread() verwenden sollte, wenn ich parallel auf Datenbanktabellen zugreifen.

Wenn ich zum Beispiel Schedulers.io() verwende, um die Datensätze aus Tausenden von Tabellen parallel auszuwählen, befanden sich viele neu erstellte Threads im Thread-Pool nach dem Task.

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 
    })... 

Wenn jedoch eine solche Aufgabe eine nächtliche Partie waren, diese Themen müssen im Thread-Pool nicht sein, da die meisten von ihnen nicht in die meiste Zeit benötigt wurden.

In diesem Fall denke ich, dass ich Schedulers.newThread() verwenden sollte. Ist es richtig?

Answer 1

Wenn Sie io arbeiten parallel begrenzen wollen, dann verwenden Sie eine benutzerdefinierte Scheduler:

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