JAva 8 parallelStreamパフォーマンステスト

シーケンス

本文は主にparallelStreamの性能を研究する.

テスト1

@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.NANOSECONDS)
@Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS)
@Measurement(iterations = 20, time = 3, timeUnit = TimeUnit.SECONDS)
@Fork(1)
@State(Scope.Benchmark)
public class StreamBenchTest {
    List data = new ArrayList<>();

    @Setup
    public void init() {
        // prepare
        for(int i=0;i<100;i++){
            data.add(UUID.randomUUID().toString());
        }
    }

    @TearDown
    public void destory() {
        // destory
    }

    @Benchmark
    public void benchStream(){
        data.stream().forEach(e -> {
            e.getBytes();
            try {
                Thread.sleep(10);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        });
    }

    @Benchmark
    public void benchParallelStream(){
        data.parallelStream().forEach(e -> {
            e.getBytes();
            try {
                Thread.sleep(10);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        });
    }

    public static void main(String[] args) throws RunnerException {
        Options opt = new OptionsBuilder()
                .include(".*" +StreamBenchTest.class.getSimpleName()+ ".*")
                .forks(1)
                .build();
        new Runner(opt).run();
    }

}

parallelStreamスレッド数

デフォルトはRuntimeです.getRuntime().AVailableProcessors(-1,ここでは7

実行結果

# Run complete. Total time: 00:02:44

Benchmark                            Mode  Cnt           Score         Error  Units
StreamBenchTest.benchParallelStream  avgt   20   155868805.437 ± 1509175.840  ns/op
StreamBenchTest.benchStream          avgt   20  1147570372.950 ± 6138494.414  ns/op

テスト2

データdataを30に変更し、sleepを100に変更

Benchmark                            Mode  Cnt           Score         Error  Units
StreamBenchTest.benchParallelStream  avgt   20   414230854.631 ±  725294.455  ns/op
StreamBenchTest.benchStream          avgt   20  3107250608.500 ± 4805037.628  ns/op

sleepが長ければ長いほどparallelStreamの優位性が明らかになることが分かった.

小結

parallelStreamは、ブロックシーンでより顕著な利点があり、スレッドプールの数はデフォルトでRuntimeである.getRuntime().AVailableProcessors()-1、変更が必要な場合は-Djavaを設定する.util.concurrent.ForkJoinPool.common.parallelism=8

doc

ForkJoinPoolのcommonPool関連パラメータ構成