WrapperExecutor Class — netty Architecture

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 2521–2588

    private static final class WrapperExecutor extends AbstractEventExecutor {

        private final ExecutorService wrapped = Executors.newSingleThreadExecutor();
        private final Thread eventLoopThread = get(wrapped.submit(() -> Thread.currentThread()));

        private static Thread get(java.util.concurrent.Future<Thread> future) {
            try {
                return future.get();
            } catch (Exception e) {
                throw new RuntimeException("Failed to get result of future", e);
            }
        }

        @Override
        public boolean isShuttingDown() {
            return wrapped.isShutdown();
        }

        @Override
        public Future<?> shutdownGracefully(long l, long l2, TimeUnit timeUnit) {
            throw new IllegalStateException();
        }

        @Override
        public Future<?> terminationFuture() {
            throw new IllegalStateException();
        }

        @Override
        public void shutdown() {
            wrapped.shutdown();
        }

        @Override
        public List<Runnable> shutdownNow() {
            return wrapped.shutdownNow();
        }

        @Override
        public boolean isShutdown() {
            return wrapped.isShutdown();
        }

        @Override
        public boolean isTerminated() {
            return wrapped.isTerminated();
        }

        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
            return wrapped.awaitTermination(timeout, unit);
        }

        @Override
        public EventExecutorGroup parent() {
            return null;
        }

        @Override
        public boolean inEventLoop(Thread thread) {
            return thread == eventLoopThread;
        }

        @Override
        public void execute(Runnable command) {
            wrapped.execute(command);
        }
    }