如何使用RxJava为集合中的每个元素并行调用方法

Question

我有以下两个方法，需要为列表中的所有名称并行调用findDetails（name）方法。如何使用RxJava实现这一点？基本上，我想在不同的线程中为集合中的每个元素调用findDetails方法。

public List<Bean> findStudentDetails(List<String> names){

        names.forEach(s->{
            findDetails(s);
         });

}


private Bean findDetails(String name){
           //some io operation
         } 

Answer 1

使用应用的subscribeOn操作符，使您的方法返回可观察，然后返回平面图您的可观察：

private Observable<Bean> findDetails(String name) {
    return Observable.fromCallable(() -> { //or any other creation method
        //some io operation
    }
}

public Observable<List<Bean>> findStudentDetails(List<String> names) {
    return Observable.from(names)
        .flatMap(s -> findDetails(s).subscribeOn(Schedulers.computation())
        .toList()
}

注意：计算Scheduler将线程计数限制为可用CPU内核的数量，以便在高强度操作中获得更好的性能。有关更多信息，请查看这个关于调度器的伟大答案-https://stackoverflow.com/a/31282775/7045114

还可以查看这篇关于并行化的文章-http://tomstechnicalblog.blogspot.ru/2015/11/rxjava-achieving-parallelization.html