8287904: Reduce runtime of java.net microbenchmarks

Reviewed-by: jvernee

test/micro/org/openjdk/bench/java/net/DatagramChannelSendReceive.java

@@ -24,6 +24,8 @@ package org.openjdk.bench.java.net;
 
 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.Param;
@@ -31,6 +33,7 @@ import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
 
 import java.net.InetSocketAddress;
 import java.nio.ByteBuffer;
@@ -46,6 +49,9 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.MICROSECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(3)
 public class DatagramChannelSendReceive {
 
     private int counter = 0;
@@ -55,7 +61,7 @@ public class DatagramChannelSendReceive {
             connectedReadChannel, multipleReceiveChannel, multipleSendChannel;
     private DatagramChannel[] dca;
 
-    @Param({"128", "512", "2048", "8192", "32768"})
+    @Param({"128", "32768"})
     public int size;
     @Param({"4"})
     public int channelCount;

test/micro/org/openjdk/bench/java/net/DatagramSocketSendReceive.java

@@ -24,6 +24,8 @@ package org.openjdk.bench.java.net;
 
 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.Param;
@@ -31,6 +33,7 @@ import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
 
 import java.util.concurrent.TimeUnit;
 import java.io.IOException;
@@ -44,6 +47,9 @@ import java.net.InetAddress;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.MICROSECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(3)
 public class DatagramSocketSendReceive {
     private int counter = 0;
 
@@ -55,7 +61,7 @@ public class DatagramSocketSendReceive {
     private DatagramSocket[] dsa;
     private DatagramPacket[] pkts;
 
-    @Param({"128", "512", "2048", "8192", "32768"})
+    @Param({"128", "32768"})
     public int size;
 
     @Param({"4"})

test/micro/org/openjdk/bench/java/net/DatagramSocketTest.java

@@ -1,75 +0,0 @@
-/*
- * Copyright (c) 2014, Oracle and/or its affiliates. All rights reserved.
- * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
- *
- * This code is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License version 2 only, as
- * published by the Free Software Foundation.
- *
- * This code is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
- * version 2 for more details (a copy is included in the LICENSE file that
- * accompanied this code).
- *
- * You should have received a copy of the GNU General Public License version
- * 2 along with this work; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
- *
- * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
- * or visit www.oracle.com if you need additional information or have any
- * questions.
- */
-package org.openjdk.bench.java.net;
-
-import org.openjdk.jmh.annotations.Benchmark;
-import org.openjdk.jmh.annotations.BenchmarkMode;
-import org.openjdk.jmh.annotations.Mode;
-import org.openjdk.jmh.annotations.OutputTimeUnit;
-import org.openjdk.jmh.annotations.Param;
-import org.openjdk.jmh.annotations.Scope;
-import org.openjdk.jmh.annotations.Setup;
-import org.openjdk.jmh.annotations.State;
-import org.openjdk.jmh.annotations.TearDown;
-
-import java.io.IOException;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
-import java.net.InetAddress;
-import java.net.SocketException;
-import java.net.UnknownHostException;
-import java.util.concurrent.TimeUnit;
-
-/**
- * DatagramSocket micros designed to stress UDP performance.
- */
-@BenchmarkMode(Mode.AverageTime)
-@OutputTimeUnit(TimeUnit.MICROSECONDS)
-@State(Scope.Thread)
-public class DatagramSocketTest {
-
-    @Param({"1024", "2048", "4096", "8192", "16384", "32768"})
-    int size;
-
-    private DatagramSocket socket;
-    private DatagramPacket packet;
-
-    @Setup
-    public void prepare() throws SocketException, UnknownHostException {
-        socket = new DatagramSocket();
-
-        byte[] buf = new byte[size];
-        packet = new DatagramPacket(buf, buf.length, InetAddress.getByName("localhost"), 9877);
-    }
-
-    @TearDown
-    public void cleanup() {
-        socket.close();
-    }
-
-    @Benchmark
-    public void testSend() throws IOException {
-        socket.send(packet);
-    }
-
-}

test/micro/org/openjdk/bench/java/net/NetworkInterfaceLookup.java

@@ -45,9 +45,9 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.Throughput)
 @OutputTimeUnit(TimeUnit.SECONDS)
 @State(Scope.Thread)
-@Fork(2)
+@Fork(value = 2, jvmArgsAppend = "--add-opens=java.base/java.net=ALL-UNNAMED")
-@Warmup(iterations = 5, time = 2)
+@Warmup(iterations = 5, time = 1)
-@Measurement(iterations = 10, time = 2)
+@Measurement(iterations = 5, time = 1)
 public class NetworkInterfaceLookup {
 
     static final InetAddress address = InetAddress.getLoopbackAddress();

test/micro/org/openjdk/bench/java/net/SocketChannelCompare.java

@@ -1,193 +0,0 @@
-/*
- * Copyright (c) 2020, Oracle and/or its affiliates. All rights reserved.
- * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
- *
- * This code is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License version 2 only, as
- * published by the Free Software Foundation.
- *
- * This code is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
- * version 2 for more details (a copy is included in the LICENSE file that
- * accompanied this code).
- *
- * You should have received a copy of the GNU General Public License version
- * 2 along with this work; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
- *
- * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
- * or visit www.oracle.com if you need additional information or have any
- * questions.
- */
-package org.openjdk.bench.java.net;
-
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-import java.net.StandardProtocolFamily;
-import java.net.UnixDomainSocketAddress;
-import java.nio.ByteBuffer;
-import java.nio.channels.ClosedChannelException;
-import java.nio.channels.ServerSocketChannel;
-import java.nio.channels.SocketChannel;
-import java.nio.file.*;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
-
-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;
-
-/**
- * Tests sending a 128 byte message on a second, to a thread which
- * echo's it back and received by the original thread.
- * Benchmark is performed for "inet" channels over TCP/IP
- * and "unix" domain channels.
- */
-@BenchmarkMode(Mode.Throughput)
-@OutputTimeUnit(TimeUnit.MILLISECONDS)
-@State(Scope.Thread)
-public class SocketChannelCompare {
-
-    static final int BUFSIZE = 128; // message size sent and received
-    private ServerSocketChannel ssc;
-    private SocketChannel s1, s2;
-    private EchoThread rt;
-    private ByteBuffer bb = ByteBuffer.allocate(BUFSIZE);
-
-    private static volatile String tempDir;
-    private static final AtomicInteger count = new AtomicInteger(0);
-    private volatile Path socket;
-
-    @Param({"inet", "unix"})
-    private volatile String family;
-
-    static {
-        try {
-            Path p = Files.createTempDirectory("readWriteTest");
-            tempDir = p.toString();
-        } catch (IOException e) {
-            tempDir = null;
-        }
-    }
-
-    private ServerSocketChannel getServerSocketChannel() throws IOException {
-        if (family.equals("inet"))
-            return getInetServerSocketChannel();
-        else if (family.equals("unix"))
-            return getUnixServerSocketChannel();
-        throw new InternalError();
-    }
-
-
-    private ServerSocketChannel getInetServerSocketChannel() throws IOException {
-        InetAddress iaddr = InetAddress.getLoopbackAddress();
-        return ServerSocketChannel.open().bind(null);
-    }
-
-    private ServerSocketChannel getUnixServerSocketChannel() throws IOException {
-        int next = count.incrementAndGet();
-        socket = Paths.get(tempDir, Integer.toString(next));
-        UnixDomainSocketAddress addr = UnixDomainSocketAddress.of(socket);
-        return ServerSocketChannel.open(StandardProtocolFamily.UNIX).bind(addr);
-    }
-
-    @Setup(Level.Trial)
-    public void beforeRun() throws IOException {
-        ssc = getServerSocketChannel();
-        s1 = SocketChannel.open(ssc.getLocalAddress());
-        s2 = ssc.accept();
-
-        rt = new EchoThread(s2);
-        rt.start();
-    }
-
-    @TearDown(Level.Trial)
-    public void afterRun() throws IOException, InterruptedException {
-        s1.close();
-        s2.close();
-        ssc.close();
-        if (family.equals("unix")) {
-            Files.delete(socket);
-            Files.delete(Path.of(tempDir));
-        }
-        rt.join();
-    }
-
-    @Benchmark
-    public void test() throws IOException {
-        bb.position(0).limit(BUFSIZE);
-        s1.write(bb);
-        bb.clear();
-        readFully(s1, bb);
-    }
-
-    // read until buf is full, or EOF. Always returns number of bytes read
-
-    static int readFully(SocketChannel chan, ByteBuffer buf) throws IOException {
-        int n = buf.remaining();
-        int count = 0;
-        while (n > 0) {
-            int c = chan.read(buf);
-            if (c == -1)
-                return count;
-            n -= c;
-            count += c;
-        }
-        return count;
-    }
-
-    static class EchoThread extends Thread {
-        private SocketChannel sc;
-
-        public EchoThread(SocketChannel s2) {
-            this.sc = s2;
-        }
-
-        public void run() {
-            try {
-                ByteBuffer bb = ByteBuffer.allocate(BUFSIZE);
-                while (true) {
-                    bb.clear();
-                    int c = readFully(sc, bb);
-                    if (c == 0) {
-                        sc.close();
-                        return;
-                    }
-                    bb.flip();
-                    sc.write(bb);
-                }
-            } catch (ClosedChannelException ex) {
-                // shutdown time
-            } catch (IOException ioex) {
-                ioex.printStackTrace();
-            }
-        }
-    }
-
-    public static void main(String[] args) throws RunnerException {
-        Options opt = new OptionsBuilder()
-                .include(org.openjdk.bench.java.net.SocketChannelCompare.class.getSimpleName())
-                .warmupForks(1)
-                .warmupIterations(2)
-                .measurementIterations(2)
-                .forks(2)
-                .build();
-
-        new Runner(opt).run();
-
-        opt = new OptionsBuilder()
-                .include(org.openjdk.bench.java.net.SocketChannelCompare.class.getSimpleName())
-                .warmupForks(1)
-                .warmupIterations(2)
-                .measurementIterations(2)
-                .jvmArgsPrepend("-Djdk.net.useFastTcpLoopback=true")
-                .forks(3)
-                .build();
-
-        new Runner(opt).run();
-    }
-}

test/micro/org/openjdk/bench/java/net/SocketChannelConnectionSetup.java

@@ -46,6 +46,9 @@ import org.openjdk.jmh.runner.options.OptionsBuilder;
 @BenchmarkMode(Mode.SingleShotTime)
 @OutputTimeUnit(TimeUnit.MILLISECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(value = 3)
 public class SocketChannelConnectionSetup {
 
     private ServerSocketChannel ssc;

test/micro/org/openjdk/bench/java/net/SocketChannelReadWrite.java

@@ -1,100 +0,0 @@
-/*
- * Copyright (c) 2014, Oracle and/or its affiliates. All rights reserved.
- * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
- *
- * This code is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License version 2 only, as
- * published by the Free Software Foundation.
- *
- * This code is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
- * version 2 for more details (a copy is included in the LICENSE file that
- * accompanied this code).
- *
- * You should have received a copy of the GNU General Public License version
- * 2 along with this work; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
- *
- * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
- * or visit www.oracle.com if you need additional information or have any
- * questions.
- */
-package org.openjdk.bench.java.net;
-
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-import java.nio.ByteBuffer;
-import java.nio.channels.ClosedChannelException;
-import java.nio.channels.ServerSocketChannel;
-import java.nio.channels.SocketChannel;
-import java.util.concurrent.TimeUnit;
-
-import org.openjdk.jmh.annotations.*;
-
-/**
- * Tests the overheads of I/O API.
- * This test is known to depend heavily on network conditions and paltform.
- */
-@BenchmarkMode(Mode.Throughput)
-@OutputTimeUnit(TimeUnit.MILLISECONDS)
-@State(Scope.Thread)
-public class SocketChannelReadWrite {
-
-    private ServerSocketChannel ssc;
-    private SocketChannel s1, s2;
-    private ReadThread rt;
-    private ByteBuffer bb = ByteBuffer.allocate(1);
-
-    @Setup(Level.Trial)
-    public void beforeRun() throws IOException {
-        InetAddress iaddr = InetAddress.getLocalHost();
-
-        ssc = ServerSocketChannel.open().bind(null);
-        s1 = SocketChannel.open(new InetSocketAddress(iaddr, ssc.socket().getLocalPort()));
-        s2 = ssc.accept();
-
-        rt = new ReadThread(s2);
-        rt.start();
-
-        bb.put((byte) 47);
-        bb.flip();
-    }
-
-    @TearDown(Level.Trial)
-    public void afterRun() throws IOException, InterruptedException {
-        s1.close();
-        s2.close();
-        ssc.close();
-        rt.join();
-    }
-
-    @Benchmark
-    public void test() throws IOException {
-        s1.write(bb);
-        bb.flip();
-    }
-
-    static class ReadThread extends Thread {
-        private SocketChannel sc;
-
-        public ReadThread(SocketChannel s2) {
-            this.sc = s2;
-        }
-
-        public void run() {
-            try {
-                ByteBuffer bb = ByteBuffer.allocate(1);
-                while (sc.read(bb) > 0) {
-                    bb.flip();
-                }
-            } catch (ClosedChannelException ex) {
-                // shutdown time
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
-}

test/micro/org/openjdk/bench/java/net/SocketReadWrite.java

@@ -24,6 +24,8 @@ package org.openjdk.bench.java.net;
 
 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.Param;
@@ -31,6 +33,7 @@ import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -51,8 +54,17 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.Throughput)
 @OutputTimeUnit(TimeUnit.SECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 10, time = 1)
+@Measurement(iterations = 5, time = 2)
+@Fork(value = 3)
 public class SocketReadWrite {
 
+    @Param({"1", "8192", "128000"})
+    public int size;
+
+    @Param({"false", "true"})
+    public boolean timeout;
+
     static final InetAddress address = InetAddress.getLoopbackAddress();
     public static final int TIMEOUT = 10000;
 
@@ -173,12 +185,6 @@ public class SocketReadWrite {
 
     EchoServer server;
 
-    @Param({"1", "1024", "8192", "64000", "128000"})
-    public int size;
-
-    @Param({"false", "true"})
-    public boolean timeout;
-
     Socket s;
     InputStream in;
     OutputStream out;

test/micro/org/openjdk/bench/java/net/SocketStreaming.java

@@ -24,12 +24,15 @@ package org.openjdk.bench.java.net;
 
 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.Setup;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -45,6 +48,9 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.MILLISECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(value = 3)
 public class SocketStreaming {
 
     /** The bytes to write/read. */

test/micro/org/openjdk/bench/java/net/ThreadLocalParseUtil.java

@@ -23,6 +23,7 @@
 
 package org.openjdk.bench.java.net;
 
+import org.openjdk.jmh.annotations.Measurement;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Benchmark;
@@ -32,6 +33,7 @@ import org.openjdk.jmh.annotations.BenchmarkMode;
 import org.openjdk.jmh.annotations.Mode;
 import org.openjdk.jmh.annotations.OutputTimeUnit;
 import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.Warmup;
 
 import java.lang.invoke.MethodHandle;
 import java.lang.invoke.MethodHandles;
@@ -44,6 +46,8 @@ import static java.lang.invoke.MethodType.methodType;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.NANOSECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
 @Fork(value = 1, jvmArgsAppend = "--add-exports=java.base/sun.net.www=ALL-UNNAMED")
 public class ThreadLocalParseUtil {
 

test/micro/org/openjdk/bench/java/net/ThreadLocalURI.java

@@ -23,6 +23,8 @@
 
 package org.openjdk.bench.java.net;
 
+import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Measurement;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Benchmark;
@@ -30,6 +32,8 @@ import org.openjdk.jmh.annotations.CompilerControl;
 import org.openjdk.jmh.annotations.BenchmarkMode;
 import org.openjdk.jmh.annotations.Mode;
 import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Warmup;
+
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.concurrent.TimeUnit;
@@ -37,6 +41,9 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.NANOSECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(value = 3)
 public class ThreadLocalURI {
 
     @Benchmark

test/micro/org/openjdk/bench/java/net/URLEncodeDecode.java

@@ -24,12 +24,15 @@ package org.openjdk.bench.java.net;
 
 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.Param;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.annotations.Warmup;
 import org.openjdk.jmh.infra.Blackhole;
 
 import java.io.UnsupportedEncodingException;
@@ -43,6 +46,9 @@ import java.util.concurrent.TimeUnit;
 @BenchmarkMode(Mode.AverageTime)
 @OutputTimeUnit(TimeUnit.MILLISECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(value = 3)
 public class URLEncodeDecode {
 
     @Param("1024")

test/micro/org/openjdk/bench/java/net/UnixSocketChannelReadWrite.java

@@ -42,6 +42,9 @@ import org.openjdk.jmh.annotations.*;
 @BenchmarkMode(Mode.Throughput)
 @OutputTimeUnit(TimeUnit.MILLISECONDS)
 @State(Scope.Thread)
+@Warmup(iterations = 5, time = 1)
+@Measurement(iterations = 5, time = 1)
+@Fork(value = 3)
 public class UnixSocketChannelReadWrite {
 
     private ServerSocketChannel ssc;