- public ProcessThreadGroup(ProcessThread processThread) {
- super("SLC Process #" + processThread.getSlcProcess().getUuid()
+ private final static Integer STEPS_BUFFER_CAPACITY = 5000;
+
+ private BlockingQueue<ExecutionStep> steps = new ArrayBlockingQueue<ExecutionStep>(
+ STEPS_BUFFER_CAPACITY);
+
+ public ProcessThreadGroup(ExecutionModulesManager executionModulesManager,
+ ProcessThread processThread) {
+ super("SLC Process #" + processThread.getProcess().getUuid()