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

Three more tweaks. #2413

Browse source
This commit is contained in:
Björn Antonsson 2012-10-02 11:09:38 +02:00
parent 086e1a0363
commit aa0d4f4cfb
3 changed files with 16 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor/src/main/resources/reference.conf
View file

@ -239,8 +239,8 @@ akka {
# calculating: ceil(available processors * factor) # calculating: ceil(available processors * factor)
max-pool-size-factor = 3.0 max-pool-size-factor = 3.0
# Max number of threads to cap factor-based max number to (if using a # Max number of threads to cap factor-based max number to
# bounded task queue) # (if using a bounded task queue)
max-pool-size-max = 64 max-pool-size-max = 64
# Specifies the bounded capacity of the task queue (< 1 == unbounded) # Specifies the bounded capacity of the task queue (< 1 == unbounded)

2
akka-docs/rst/scala/actors.rst
View file

@ -353,7 +353,7 @@ paths—logical or physical—and receive back an :class:`ActorRef` with the
result:: result::
context.actorFor("/user/serviceA/aggregator") // will look up this absolute path context.actorFor("/user/serviceA/aggregator") // will look up this absolute path
context.actorFor("../joe") // will look up sibling beneath same supervisor context.actorFor("../joe") // will look up sibling beneath same supervisor
The supplied path is parsed as a :class:`java.net.URI`, which basically means The supplied path is parsed as a :class:`java.net.URI`, which basically means
that it is split on ``/`` into path elements. If the path starts with ``/``, it that it is split on ``/`` into path elements. If the path starts with ``/``, it

25
akka-docs/rst/scala/code/docs/dispatcher/DispatcherDocSpec.scala
View file

@ -112,21 +112,22 @@ object DispatcherDocSpec {
// We inherit, in this case, from UnboundedPriorityMailbox // We inherit, in this case, from UnboundedPriorityMailbox
// and seed it with the priority generator // and seed it with the priority generator
class MyPrioMailbox(settings: ActorSystem.Settings, config: Config) extends UnboundedPriorityMailbox( class MyPrioMailbox(settings: ActorSystem.Settings, config: Config)
// Create a new PriorityGenerator, lower prio means more important extends UnboundedPriorityMailbox(
PriorityGenerator { // Create a new PriorityGenerator, lower prio means more important
// 'highpriority messages should be treated first if possible PriorityGenerator {
case 'highpriority ⇒ 0 // 'highpriority messages should be treated first if possible
case 'highpriority ⇒ 0
// 'lowpriority messages should be treated last if possible // 'lowpriority messages should be treated last if possible
case 'lowpriority ⇒ 2 case 'lowpriority ⇒ 2
// PoisonPill when no other left // PoisonPill when no other left
case PoisonPill ⇒ 3 case PoisonPill ⇒ 3
// We default to 1, which is in between high and low // We default to 1, which is in between high and low
case otherwise ⇒ 1 case otherwise ⇒ 1
}) })
//#prio-mailbox //#prio-mailbox
class MyActor extends Actor { class MyActor extends Actor {