package other_examples;

import com.google.common.io.CharSource;

import org.apache.commons.io.IOUtils;

import org.apache.commons.io.input.ReaderInputStream;

import org.openjdk.jmh.annotations.*;

import org.openjdk.jmh.runner.Runner;

import org.openjdk.jmh.runner.RunnerException;

import org.openjdk.jmh.runner.options.Options;

import org.openjdk.jmh.runner.options.OptionsBuilder;

import java.io.ByteArrayInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.nio.charset.StandardCharsets;

import java.util.concurrent.TimeUnit;

/**

* Created by vvedenin on 2/15/2016.

*/

@State(Scope.Benchmark)

public class ConvertBigStringToInputStreamBenchmark {

private static String test1;

/* 1. Using ToInputStream of Apache Utils */

@Benchmark

public InputStream apacheToInputStream() throws IOException {

return IOUtils.toInputStream(test1, StandardCharsets.UTF_8);

}

/* 2. Using JDK */

@Benchmark

public InputStream jdkByteArrayInputStream() throws IOException {

return new ByteArrayInputStream(test1.getBytes(StandardCharsets.UTF_8));

}

/* 3. Using ReaderInputStream of Apache Utils */

@Benchmark

public InputStream apacheReaderInputStream() throws IOException {

return new ReaderInputStream(CharSource.wrap(test1).openStream());

}

/* 4. Using Apache Utils and InputStreamReader*/

@Benchmark

public InputStream apacheInputStreamReader() throws IOException {

return IOUtils.toInputStream(test1);

}

@TearDown(Level.Iteration)

public void tearDown() {

String test = "test184768612876481276487612876417826487216478216784621784672816478216784621784621786478216478216784261784621782178647281647821647821697421687126784621874621786478216478216874";

StringBuilder builder = new StringBuilder(test);

for(int i = 0; i< 1000; i++) {

builder.append(test);

}

test1 = builder.toString();

System.out.println(test1.length());

}

public static void main(String[] args) throws RunnerException {

Options opt = new OptionsBuilder()

.include(ConvertStringToInputStreamBenchmark.class.getSimpleName())

.timeUnit(TimeUnit.MICROSECONDS)

.warmupIterations(5)

.measurementIterations(50)

.forks(1)

.mode(Mode.AverageTime)

.build();

new Runner(opt).run();

}

}