public static final class AbstractSharedExecutorMicrobenchmark.DelegateHarnessExecutor
extends io.netty.util.concurrent.AbstractEventExecutor
executor(EventLoop)
with the EventLoop used by Netty.| Constructor and Description |
|---|
DelegateHarnessExecutor(int maxThreads,
String prefix) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
static void |
executor(io.netty.channel.EventLoop service)
Set the executor (in the form of an
EventLoop) which JMH will use. |
boolean |
inEventLoop() |
boolean |
inEventLoop(Thread thread) |
boolean |
isShutdown() |
boolean |
isShuttingDown() |
boolean |
isTerminated() |
<V> io.netty.util.concurrent.ProgressivePromise<V> |
newProgressivePromise() |
<V> io.netty.util.concurrent.Promise<V> |
newPromise() |
void |
shutdown()
Deprecated.
|
io.netty.util.concurrent.Future<?> |
shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
io.netty.util.concurrent.Future<?> |
terminationFuture() |
iterator, lazyExecute, newFailedFuture, newSucceededFuture, newTaskFor, newTaskFor, next, parent, runTask, safeExecute, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitinvokeAll, invokeAll, invokeAny, invokeAnyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinvokeAll, invokeAll, invokeAny, invokeAnyforEach, spliteratorpublic DelegateHarnessExecutor(int maxThreads,
String prefix)
public static void executor(io.netty.channel.EventLoop service)
EventLoop) which JMH will use.
This must be called before JMH requires an executor to execute objects.
service - Used as an executor by JMH to run benchmarks.public boolean inEventLoop()
inEventLoop in interface io.netty.util.concurrent.EventExecutorinEventLoop in class io.netty.util.concurrent.AbstractEventExecutorpublic boolean inEventLoop(Thread thread)
public io.netty.util.concurrent.Future<?> shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit)
public io.netty.util.concurrent.Future<?> terminationFuture()
@Deprecated public void shutdown()
shutdown in interface io.netty.util.concurrent.EventExecutorGroupshutdown in interface ExecutorServiceshutdown in class io.netty.util.concurrent.AbstractEventExecutorpublic boolean isShuttingDown()
public boolean isShutdown()
public boolean isTerminated()
public boolean awaitTermination(long timeout,
TimeUnit unit)
public void execute(Runnable command)
public <V> io.netty.util.concurrent.Promise<V> newPromise()
newPromise in interface io.netty.util.concurrent.EventExecutornewPromise in class io.netty.util.concurrent.AbstractEventExecutorpublic <V> io.netty.util.concurrent.ProgressivePromise<V> newProgressivePromise()
newProgressivePromise in interface io.netty.util.concurrent.EventExecutornewProgressivePromise in class io.netty.util.concurrent.AbstractEventExecutorCopyright © 2008–2026 The Netty Project. All rights reserved.