Primitive arguments working

[gpl/argeo-slc.git] / runtime / org.argeo.slc.core / src / main / java / org / argeo / slc / core / execution / ProcessThread.java

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 9474656fd5ac7a8be59326974f0d2414e8251cad..dc9e7efdd8a1233d01c1ea7f05e0d69d41c34d92 100644 (file)
--- 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 {