ReadLineBenchmark.java

package io.github.kavahub.file.performance;

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.BenchmarkMode;
import org.openjdk.jmh.annotations.Fork;
import org.openjdk.jmh.annotations.Measurement;
import org.openjdk.jmh.annotations.Mode;
import org.openjdk.jmh.annotations.OutputTimeUnit;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.Warmup;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.ChainedOptionsBuilder;
import org.openjdk.jmh.runner.options.OptionsBuilder;

import io.github.kavahub.file.reader.AIOFileReader;
import io.github.kavahub.file.reader.NIOFileLineReader;


/**
 * 逐行读取性能测试
 * 
 * <p>
 * 测试结果：
 * 
 * <pre>
 * Benchmark                                          Mode  Cnt    Score    Error  Units
 * ReadLineBenchmark.readLineUsingAsyncReader        thrpt   10  373.187 ± 53.861  ops/s
 * ReadLineBenchmark.readLineUsingJavaFiles          thrpt   10  282.852 ± 41.247  ops/s
 * ReadLineBenchmark.readLineUsingNIOFileLineReader  thrpt   10  256.296 ± 10.875  ops/s
 * </pre>
 */
@State(Scope.Benchmark)
@BenchmarkMode(Mode.Throughput)
@OutputTimeUnit(TimeUnit.SECONDS)
@Measurement(iterations = 10, time = 1)
@Warmup(iterations = 1)
@Fork(1)
public class ReadLineBenchmark {
    private final static Path file = Paths.get("src", "test", "resources", "fileWithmanyOfLine.txt");
    
    public static void main(String[] args) throws Exception {
        ChainedOptionsBuilder opts = new OptionsBuilder().include(ReadLineBenchmark.class.getSimpleName());

        new Runner(opts.threads(8).build()).run();
    }

    @Benchmark
    public List<String> readLineUsingJavaFiles() throws IOException {
        return Files.readAllLines(file);
    }

    @Benchmark
    public List<String> readLineUsingAsyncReader(){
        List<String> result = new ArrayList<>();
        AIOFileReader.line(file).subscribe(data -> result.add(data), err -> err.printStackTrace()).join();

        return result;
    }

    @Benchmark
    public List<String> readLineUsingNIOFileLineReader(){
        List<String> result = new ArrayList<>();
        NIOFileLineReader.read(file).subscribe(data-> result.add(data), err -> err.printStackTrace()).join();
        return result;
    }
}