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

Refactoring RemoteServer

Browse source
This commit is contained in:
Viktor Klang 2010-09-07 10:12:26 +02:00
parent 4841996520
commit fd480e9d76
4 changed files with 35 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-actor/src/main/scala/dispatch/ThreadPoolBuilder.scala
View file

@ -46,7 +46,7 @@ trait ThreadPoolBuilder extends Logging {
if (boundedExecutorBound > 0) {
val boundedExecutor = new BoundedExecutorDecorator(threadPoolBuilder, boundedExecutorBound)
boundedExecutorBound = -1
boundedExecutorBound = -1 //Why is this here?
executor = boundedExecutor
} else {
executor = threadPoolBuilder
@ -208,7 +208,7 @@ trait ThreadPoolBuilder extends Logging {
/**
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/
class BoundedExecutorDecorator(val executor: ExecutorService, bound: Int) extends ExecutorService {
class BoundedExecutorDecorator(val executor: ExecutorService, bound: Int) extends ExecutorService with Logging {
protected val semaphore = new Semaphore(bound)
def execute(command: Runnable) = {
@ -226,6 +226,9 @@ trait ThreadPoolBuilder extends Logging {
} catch {
case e: RejectedExecutionException =>
semaphore.release
case e =>
log.error(e,"Unexpected exception")
throw e
}
}