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

Allow core threads to time out in dispatchers

Browse source
This commit is contained in:
Viktor Klang 2010-08-12 13:39:20 +02:00
parent 1513c2c0c4
commit 94e01628f0
1 changed files with 1 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
akka-core/src/main/scala/dispatch/ThreadPoolBuilder.scala
View file

@ -34,6 +34,7 @@ trait ThreadPoolBuilder {
def buildThreadPool(): Unit = synchronized { def buildThreadPool(): Unit = synchronized {
ensureNotActive ensureNotActive
inProcessOfBuilding = false inProcessOfBuilding = false
threadPoolBuilder.allowCoreThreadTimeOut(true)
if (boundedExecutorBound > 0) { if (boundedExecutorBound > 0) {
val boundedExecutor = new BoundedExecutorDecorator(threadPoolBuilder, boundedExecutorBound) val boundedExecutor = new BoundedExecutorDecorator(threadPoolBuilder, boundedExecutorBound)
boundedExecutorBound = -1 boundedExecutorBound = -1