X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FProcessThreadGroup.java;h=03b72f6052adad7ae80b38ac58c23eb7acd842b0;hb=098e868d40b2130c6735b1547247c61a5d88da95;hp=23d165a4c25066283cc87e4090c703afdceefbb6;hpb=9b2422e7198df6f34282a805058dd5f497417318;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java index 23d165a4c..03b72f605 100644 --- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java +++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/ProcessThreadGroup.java @@ -28,11 +28,12 @@ import org.argeo.slc.process.SlcExecution; import org.argeo.slc.process.SlcExecutionStep; /** The thread group attached to a given {@link SlcExecution}. */ +@SuppressWarnings("deprecation") public class ProcessThreadGroup extends ThreadGroup { private final ExecutionModulesManager executionModulesManager; private final ProcessThread processThread; - - private final static Integer STEPS_BUFFER_CAPACITY = 10000; +// private final Authentication authentication; + private final static Integer STEPS_BUFFER_CAPACITY = 5000; private BlockingQueue steps = new ArrayBlockingQueue( STEPS_BUFFER_CAPACITY); @@ -43,11 +44,13 @@ public class ProcessThreadGroup extends ThreadGroup { + " thread group"); this.executionModulesManager = executionModulesManager; this.processThread = processThread; +// this.authentication = SecurityContextHolder.getContext() +// .getAuthentication(); } - // public SlcExecution getSlcProcess() { - // return processThread.getSlcProcess(); - // } +// public Authentication getAuthentication() { +// return authentication; +// } public void dispatchAddStep(ExecutionStep step) { // legacy