[Swift-commit] r5741 - trunk/src/org/griphyn/vdl/karajan/lib/cache

[hategan at ci.uchicago.edu]

Author: hategan
Date: 2012-04-03 02:14:28 -0500 (Tue, 03 Apr 2012)
New Revision: 5741

Modified:
   trunk/src/org/griphyn/vdl/karajan/lib/cache/File.java
Log:
uncommitted deadlock fix from 0.93

Modified: trunk/src/org/griphyn/vdl/karajan/lib/cache/File.java
===================================================================
--- trunk/src/org/griphyn/vdl/karajan/lib/cache/File.java	2012-04-03 01:48:43 UTC (rev 5740)
+++ trunk/src/org/griphyn/vdl/karajan/lib/cache/File.java	2012-04-03 07:14:28 UTC (rev 5741)
@@ -26,6 +26,7 @@
 
 import org.globus.cog.karajan.stack.VariableStack;
 import org.globus.cog.karajan.workflow.ExecutionException;
+import org.globus.cog.karajan.workflow.events.EventBus;
 import org.globus.cog.karajan.workflow.futures.Future;
 import org.globus.cog.karajan.workflow.futures.FutureEvaluationException;
 import org.globus.cog.karajan.workflow.futures.FutureListener;
@@ -169,9 +170,13 @@
 		if (listeners != null) {
 			Iterator<ListenerStackPair> i = listeners.iterator();
 			while (i.hasNext()) {
-				ListenerStackPair etp = i.next();
+				final ListenerStackPair etp = i.next();
 				i.remove();
-				etp.listener.futureModified(this, etp.stack);
+				EventBus.post(new Runnable() {
+                    public void run() {
+                        etp.listener.futureModified(File.this, etp.stack);
+                    }				    
+				});
 			}
 		}
 	}