Configure Actor mailbox as a BlockingDeque
Use: BoundedTransferQueue => http://github.com/jboner/akka/blob/master/akka-actor/src/main/scala/dispatch/Queues.scala#L12
Should we solve it by adding this? // if mailboxSize is negative then use unbounded, if positive create a BlockingDeque with the size def actorOf[T <: Actor: Manifest](mailboxSize = -1): ActorRef = new LocalActorRef(manifest[T].erasure.asInstanceOf[Class[_ <: Actor]], mailboxSize) val actor = actorOf[MyActor](mailboxSize = 100) Or should we do as we do with the new STM stuff? E.g. accept an implicit ActorRefConfig that can do more? def actorOf[T <: Actor: Manifest](implicit config: ActorRefConfig = DefaultActorRefConfig()): ActorRef = new LocalActorRef(manifest[T].erasure.asInstanceOf[Class[_ <: Actor]], config) Thoughts?
Leave a comment
on 2010-08-26 08:00 *
By viktorklang
What is the purpose/feature of this ticket?
blocking sends?
It feels like we probably need to make sure we're not mixing apples and pears for the same dispatcher, no?
Is there a usecase where a non-timeouted block is desired?
blocking sends?
It feels like we probably need to make sure we're not mixing apples and pears for the same dispatcher, no?
Is there a usecase where a non-timeouted block is desired?
on 2010-09-01 07:52 *
By viktorklang
Description changed from http://gee.cs.oswego.edu/dl... to Use: BoundedTransferQueue =...