[Swift-commit] r5262 - branches/release-0.93/src/org/griphyn/vdl/karajan

[hategan at ci.uchicago.edu]

Author: hategan
Date: 2011-10-29 19:57:07 -0500 (Sat, 29 Oct 2011)
New Revision: 5262

Modified:
   branches/release-0.93/src/org/griphyn/vdl/karajan/ArrayIndexFutureList.java
Log:
fixed deadlock

Modified: branches/release-0.93/src/org/griphyn/vdl/karajan/ArrayIndexFutureList.java
===================================================================
--- branches/release-0.93/src/org/griphyn/vdl/karajan/ArrayIndexFutureList.java	2011-10-29 02:55:13 UTC (rev 5261)
+++ branches/release-0.93/src/org/griphyn/vdl/karajan/ArrayIndexFutureList.java	2011-10-30 00:57:07 UTC (rev 5262)
@@ -11,6 +11,7 @@
 import java.util.Set;
 
 import org.globus.cog.karajan.stack.VariableStack;
+import org.globus.cog.karajan.workflow.events.EventBus;
 import org.globus.cog.karajan.workflow.events.EventTargetPair;
 import org.globus.cog.karajan.workflow.futures.FutureEvaluationException;
 import org.globus.cog.karajan.workflow.futures.FutureIterator;
@@ -115,9 +116,14 @@
             listeners = null;
         }
         
-        for (ListenerStackPair lsp : l) {
+        for (final ListenerStackPair lsp : l) {
             WaitingThreadsMonitor.removeThread(lsp.stack);
-            lsp.listener.futureModified(this, lsp.stack);
+            EventBus.post(new Runnable() {
+                @Override
+                public void run() {
+                    lsp.listener.futureModified(ArrayIndexFutureList.this, lsp.stack);
+                }
+            });
         }
     }