Hey all. Ive got an Actor set up that when called, takes a little bit of time to run and I want to limit how many "runs" happen at the same time. I have a routing pool above this actor to accomplish that. However, in my current implementation of the actor I am blocking to get that functionality, and I definitely dont want to lose that thread to a blocking call.
If I use Future.pipeTo(sender()), the actor than pulls from the mailbox almost immediately causing more work to be run that I would like. Im guessing I am either missing something simple, or there is a better pattern out there to solve this problem? class ArchiveActor (workerClass: Worker) extends Actor with Logging { import context.dispatcher private def run(minute: DateTime): Future[ArchiveResult] = { // work is done here that returns a future workerClass.doWork(minute) } override def receive: Receive = { case Run(minute) => sender().tell(Await.result(run(minute), Duration.Inf), context.parent) } -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.