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

Fixing logic bug introduced in refactor

Browse source
This commit is contained in:
Viktor Klang 2012-05-21 13:39:39 +02:00
parent 22f0062f23
commit 7784513537
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala
View file

@ -87,7 +87,7 @@ class BalancingDispatcher(
@tailrec def scheduleOne(i: Iterator[ActorCell] = team.iterator): Unit =
if (messageQueue.hasMessages
&& i.hasNext
&& (executorService match {
&& (executorService.executor match {
case lm: LoadMetrics ⇒ lm.atFullThrottle == false
case other ⇒ true
})

2
akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala
View file

@ -41,7 +41,7 @@ class Dispatcher(
@volatile private var executorServiceDelegate: LazyExecutorServiceDelegate =
new LazyExecutorServiceDelegate(executorServiceFactoryProvider.createExecutorServiceFactory(id, prerequisites.threadFactory))
protected final def executorService: ExecutorService = executorServiceDelegate
protected final def executorService: ExecutorServiceDelegate = executorServiceDelegate
/**
* INTERNAL USE ONLY