diff --git a/transport/src/main/java/io/netty/channel/socket/oio/OioChildEventLoop.java b/transport/src/main/java/io/netty/channel/socket/oio/OioChildEventLoop.java index 0313f0cb2b..81d83d5dc7 100644 --- a/transport/src/main/java/io/netty/channel/socket/oio/OioChildEventLoop.java +++ b/transport/src/main/java/io/netty/channel/socket/oio/OioChildEventLoop.java @@ -53,8 +53,11 @@ class OioChildEventLoop extends SingleThreadEventLoop { } } - if (isShutdown() && peekTask() == null) { - break; + if (isShutdown()) { + ch.unsafe().close(ch.unsafe().voidFuture()); + if (peekTask() == null) { + break; + } } } }