netty Architecture Docs
Home / Function/ HarnessExecutor() — netty Function Reference

HarnessExecutor() — netty Function Reference

Architecture documentation for the HarnessExecutor() function in AbstractMicrobenchmark.java from the netty codebase.

Function java Buffer Search

Entity Profile

Dependency Diagram

graph TD
  38deadc8_b2a3_7442_f88a_864b3bdbbc59["HarnessExecutor()"]
  eb3ecb1d_b90c_6acb_9957_29d7b31ac030["HarnessExecutor"]
  38deadc8_b2a3_7442_f88a_864b3bdbbc59 -->|defined in| eb3ecb1d_b90c_6acb_9957_29d7b31ac030
  style 38deadc8_b2a3_7442_f88a_864b3bdbbc59 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

microbench/src/main/java/io/netty/microbench/util/AbstractMicrobenchmark.java lines 51–104

        public HarnessExecutor(int maxThreads, String prefix) {
            super(maxThreads, maxThreads, 0, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue<Runnable>(),
                    new DefaultThreadFactory(prefix));
            EventExecutor eventExecutor = new AbstractEventExecutor() {
                @Override
                public void shutdown() {
                    throw new UnsupportedOperationException();
                }

                @Override
                public boolean inEventLoop(Thread thread) {
                    return thread instanceof FastThreadLocalThread;
                }

                @Override
                public boolean isShuttingDown() {
                    throw new UnsupportedOperationException();
                }

                @Override
                public Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit) {
                    throw new UnsupportedOperationException();
                }

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

                @Override
                public boolean isShutdown() {
                    throw new UnsupportedOperationException();
                }

                @Override
                public boolean isTerminated() {
                    throw new UnsupportedOperationException();
                }

                @Override
                public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
                    throw new UnsupportedOperationException();
                }

                @Override
                public void execute(Runnable command) {
                    throw new UnsupportedOperationException();
                }
            };
            setThreadFactory(ThreadExecutorMap.apply(getThreadFactory(), eventExecutor));

            logger.debug("Using harness executor");
        }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does HarnessExecutor() do?
HarnessExecutor() is a function in the netty codebase, defined in microbench/src/main/java/io/netty/microbench/util/AbstractMicrobenchmark.java.
Where is HarnessExecutor() defined?
HarnessExecutor() is defined in microbench/src/main/java/io/netty/microbench/util/AbstractMicrobenchmark.java at line 51.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free