X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FProcessThread.java;h=dc9e7efdd8a1233d01c1ea7f05e0d69d41c34d92;hb=86c47402780f41526382267ff1597d2f3a0d0dd7;hp=9474656fd5ac7a8be59326974f0d2414e8251cad;hpb=a181e3d059185a9dc108e81f38c66f48f4e4aac8;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThread.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThread.java
index 9474656fd..dc9e7efdd 100644
--- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThread.java
+++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThread.java
@@ -103,7 +103,8 @@ public class ProcessThread extends Thread {
 		}
 	}
 
-	protected void execute(RealizedFlow realizedFlow, Boolean synchronous) {
+	/** @return the (distinct) thread used for this execution */
+	protected Thread execute(RealizedFlow realizedFlow, Boolean synchronous) {
 		ExecutionThread thread = new ExecutionThread(this, realizedFlow);
 		executionThreads.add(thread);
 		thread.start();
@@ -115,6 +116,7 @@ public class ProcessThread extends Thread {
 				log.error("Flow " + realizedFlow + " was interrupted", e);
 			}
 		}
+		return thread;
 
 		// synchronized (this) {
 		// try {