ScheduledFutureTaskDeadlineBenchmark Class — netty Architecture

Source Code

microbench/src/main/java/io/netty/util/concurrent/ScheduledFutureTaskDeadlineBenchmark.java lines 33–66

@Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS)
@Measurement(iterations = 10, time = 3, timeUnit = TimeUnit.SECONDS)
@State(Scope.Benchmark)
public class ScheduledFutureTaskDeadlineBenchmark extends AbstractMicrobenchmark {
    @State(Scope.Thread)
    public static class ThreadState {

        AbstractScheduledEventExecutor eventLoop;
        ScheduledFutureTask<?> future;

        @Setup(Level.Trial)
        public void reset() {
            eventLoop = (AbstractScheduledEventExecutor) new MultiThreadIoEventLoopGroup(
                    1, NioIoHandler.newFactory()).next();
            future = (ScheduledFutureTask<?>) eventLoop.schedule(new Runnable() {
                @Override
                public void run() {
                }
            }, 100, TimeUnit.DAYS);
        }

        @TearDown(Level.Trial)
        public void shutdown() {
            future.cancel(true);
            eventLoop.parent().shutdownGracefully().awaitUninterruptibly();
        }
    }

    @Benchmark
    @Threads(1)
    public long requestDeadline(final ThreadState threadState) {
        return threadState.future.delayNanos();
    }
}