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=893d878fd99ae6ff8d9a427bc140ecc58abdaeef;hb=86fc845e533e99358ec3de7182ea0c01bcd1c432;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..893d878fd 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 static Integer STEPS_BUFFER_CAPACITY = 5000; private BlockingQueue steps = new ArrayBlockingQueue( STEPS_BUFFER_CAPACITY); @@ -45,10 +46,6 @@ public class ProcessThreadGroup extends ThreadGroup { this.processThread = processThread; } - // public SlcExecution getSlcProcess() { - // return processThread.getSlcProcess(); - // } - public void dispatchAddStep(ExecutionStep step) { // legacy ExecutionProcess slcProcess = processThread.getProcess();