raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Merge pull request #1024 from drewhk/wip-2733-netty-workerpool-shutdown-drew

Browse source 
Fixed issue with Netty not releasing worker threads properly #2733
This commit is contained in:
drewhk 2013-01-15 05:58:17 -08:00
commit 1b533412b5
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala
View file

@ -379,7 +379,11 @@ class NettyTransport(private val settings: NettyTransportSettings, private val s
_ ← always(channelGroup.write(ChannelBuffers.buffer(0)))
_ ← always({ channelGroup.unbind(); channelGroup.disconnect() })
_ ← always(channelGroup.close())
} inboundBootstrap.releaseExternalResources()
} {
// Release the selectors, but don't try to kill the dispatcher
if (UseDispatcherForIo.isDefined) inboundBootstrap.shutdown()
else inboundBootstrap.releaseExternalResources()
}
}