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

Added support for a config flag that allows the user to reuse the default dispatcher as the ExecutorService for the Netty Remote Pipeline (IO)

Browse source
This commit is contained in:
Viktor Klang 2012-04-25 10:41:16 +02:00
parent 1f30be1f87
commit 45694c65f4
3 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-remote/src/main/scala/akka/remote/netty/Server.scala
View file

@ -26,9 +26,10 @@ class NettyRemoteServer(val netty: NettyRemoteTransport) {
val ip = InetAddress.getByName(settings.Hostname)
private val factory = new NioServerSocketChannelFactory(
Executors.newCachedThreadPool(netty.system.threadFactory),
Executors.newCachedThreadPool(netty.system.threadFactory))
private val factory = {
val boss, worker = if (settings.UseDefaultDispatcherForIO) netty.system.dispatcher else Executors.newCachedThreadPool()
new NioServerSocketChannelFactory(boss, worker)
}
private val executionHandler = new ExecutionHandler(netty.executor)