diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java index ba4f028988..af779c8b20 100644 --- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java +++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java @@ -290,6 +290,13 @@ abstract class AbstractNioWorker implements Worker { executeInIoThread(task, false); } + /** + * Execute the {@link Runnable} in a IO-Thread + * + * @param task the {@link Runnable} to execute + * @param alwaysAsync true if the {@link Runnable} should be executed in an async + * fashion even if the current Thread == IO Thread + */ public void executeInIoThread(Runnable task, boolean alwaysAsync) { if (!alwaysAsync && Thread.currentThread() == thread) { task.run();