diff --git a/multithreading1/src/main/java/cn/bunny/jmh/JMHExample14.java b/multithreading1/src/main/java/cn/bunny/jmh/JMHExample14.java new file mode 100644 index 0000000..9b95a2f --- /dev/null +++ b/multithreading1/src/main/java/cn/bunny/jmh/JMHExample14.java @@ -0,0 +1,48 @@ +package cn.bunny.jmh; + +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.util.concurrent.BlockingDeque; +import java.util.concurrent.LinkedBlockingDeque; +import java.util.concurrent.TimeUnit; + +@BenchmarkMode(Mode.AverageTime) +@Fork(1) +@Warmup(iterations = 5) +@Measurement(iterations = 5) +@OutputTimeUnit(TimeUnit.MICROSECONDS) +@State(Scope.Group) +public class JMHExample14 { + private final static int VALUE = Integer.MAX_VALUE; + private BlockingDeque queue; + + public static void main(String[] args) throws RunnerException { + final Options options = new OptionsBuilder() + .include(JMHExample14.class.getSimpleName()) + .build(); + new Runner(options).run(); + } + + @Setup + public void init() { + this.queue = new LinkedBlockingDeque<>(10); + } + + @GroupThreads(5) + @Group("blockingQueue") + @Benchmark + public void put() throws InterruptedException { + this.queue.put(VALUE); + } + + @GroupThreads(5) + @Group("blockingQueue") + @Benchmark + public int take() throws InterruptedException { + return this.queue.take(); + } +}