locking per actor and not per running map

ga2arch · Apr 25, 2016 · 52db365 · 52db365
1 parent a756bea
commit 52db365
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/gabriele/actor/internals/AbstractDispatcher.java b/src/main/java/com/gabriele/actor/internals/AbstractDispatcher.java
@@ -27,7 +27,7 @@ public abstract class AbstractDispatcher {
     public void dispatch(final ActorRef actorRef) {
         try {
             final AbstractActor actor = getSystem().getActor(actorRef);
-            synchronized (running) {
+            synchronized (actor) {
                 if (running.contains(actorRef)) return;
                 running.add(actorRef);
 
@@ -44,7 +44,7 @@ public void run() {
                             Log.e(LOG_TAG, e.getMessage(), e);
 
                         } finally {
-                            synchronized (running) {
+                            synchronized (actor) {
                                 if (!actor.isTerminated() && actor.getMailbox().size() > 0) {
                                     running.remove(actorRef);
                                     dispatch(actorRef);