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

Revert "Switching ThreadBasedDispatcher to use SynchronousQueue since only one actor should be in it"

Browse source 
This reverts commit f980dc3f23.
This commit is contained in:
Viktor Klang 2011-03-14 08:27:47 +01:00
parent 36a612eea5
commit dfca401ab0
1 changed files with 2 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-actor/src/main/scala/akka/dispatch/ThreadBasedDispatcher.scala
View file

@ -9,7 +9,7 @@ import akka.config.Config.config
import akka.util.Duration
import java.util.Queue
import java.util.concurrent.{TimeUnit, SynchronousQueue}
import java.util.concurrent.{ConcurrentLinkedQueue, BlockingQueue, TimeUnit, LinkedBlockingQueue}
import akka.actor
import java.util.concurrent.atomic.AtomicReference
@ -47,11 +47,6 @@ class ThreadBasedDispatcher(_actor: ActorRef, _mailboxType: MailboxType)
}
object ThreadBasedDispatcher {
val oneThread: ThreadPoolConfig =
ThreadPoolConfig(
allowCorePoolTimeout = true,
corePoolSize = 1,
maxPoolSize = 1,
queueFactory = () => new SynchronousQueue[Runnable])
val oneThread: ThreadPoolConfig = ThreadPoolConfig(allowCorePoolTimeout = true, corePoolSize = 1, maxPoolSize = 1)
}