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

Updated old scaladoc

Browse source
This commit is contained in:
Jonas Bonér 2010-04-16 00:02:38 +02:00
parent ce173d7351
commit 2ce690d9eb
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-core/src/main/scala/dispatch/Dispatchers.scala
View file

@ -11,7 +11,7 @@ import se.scalablesolutions.akka.actor.Actor
* <p/>
* Example usage:
* <pre/>
* val dispatcher = Dispatchers.newEventBasedThreadPoolDispatcher("name")
* val dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name")
* dispatcher
* .withNewThreadPoolWithBoundedBlockingQueue(100)
* .setCorePoolSize(16)
@ -25,7 +25,7 @@ import se.scalablesolutions.akka.actor.Actor
* <p/>
* Example usage:
* <pre/>
* MessageDispatcher dispatcher = Dispatchers.newEventBasedThreadPoolDispatcher("name");
* MessageDispatcher dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name");
* dispatcher
* .withNewThreadPoolWithBoundedBlockingQueue(100)
* .setCorePoolSize(16)
@ -40,9 +40,8 @@ import se.scalablesolutions.akka.actor.Actor
*/
object Dispatchers {
object globalExecutorBasedEventDrivenDispatcher extends ExecutorBasedEventDrivenDispatcher("global") {
override def register(actor : Actor) = {
if (isShutdown)
init
override def register(actor: Actor) = {
if (isShutdown) init
super.register(actor)
}
}