diff --git a/transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java b/transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java index 66a1acb3d0..f28a7a3037 100644 --- a/transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java +++ b/transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java @@ -42,7 +42,7 @@ class DefaultChildEventExecutor extends SingleThreadEventExecutor { @Override protected void wakeup(boolean inEventLoop) { - if (!inEventLoop) { + if (!inEventLoop && isShutdown()) { interruptThread(); } }