CODEWITHSUNDEEP
scalaconcurrencyactor
oxbow_lakes
oxbow_lakes

Reputation: 134270

Does this Scala actor block when creating new actor in a handler?

I have the following piece of code:

actor {
  loop {
     react {
       case SomeEvent =>
         //I want to submit a piece of work to a queue and then send a response 
         //when that is finished. However, I don't want *this* actor to block
         val params = "Some args"
         val f: Future[Any] = myQueue.submitWork( params );
         actor {
           //await here
           val response = f.get
           publisher ! response
         }

     }
  }
}

As I understood it, the outer actor would not block on f.get because that is actually being performed by a separate actor (the one created inside the SomeEvent handler).

Is this correct?

Upvotes: 1

Views: 794

Answers (1)

Apocalisp
Apocalisp

Reputation: 35054

Yes, that is correct. Your outer actor will simply create an actor and suspend (wait for its next message). However, be very careful of this kind of thing. The inner actor is started automatically on the scheduler, to be handled by a thread. That thread will block on that Future (that looks like a java.util.concurrent.Future to me). If you do this enough times, you can run into starvation problems where all available threads are blocking on Futures. An actor is basically a work queue, so you should use those semantics instead.

Here's a version of your code, using the Scalaz actors library. This library is much simpler and easier to understand than the standard Scala actors (the source is literally a page and a half). It also leads to much terser code:

actor {(e: SomeEvent) => promise { ... } to publisher }

This version is completely non-blocking.

Upvotes: 2

Related Questions