5
Idiomatic concurrency: flatMap() vs. parallel() . RxJava FAQ (www.nurkiewicz.com)
Kros 積分 3 編輯於
Flowable<Person> people = ids
        .parallel(10)
        .runOn(Schedulers.io())
        .map(this::slowLoadBy)
        .filter(this::hasLowRisk)
        .sequential();

小弟只寫 Android,在 Asus ZenFone 測試真的有差,不是假 Parallel XD
跑 50 筆,每一個 method 都停兩秒
Parallel: 20s
Non-Parallel: 102s