- private final ExecutionModulesManager executionModulesManager;
- private final ProcessThread processThread;
-
- public ProcessThreadGroup(ExecutionModulesManager executionModulesManager,
- ProcessThread processThread) {
- super("SLC Process #" + processThread.getSlcProcess().getUuid()
- + " thread group");
- this.executionModulesManager = executionModulesManager;
- this.processThread = processThread;
+ // private final ExecutionModulesManager executionModulesManager;
+ // private final ProcessThread processThread;
+ private final Authentication authentication;
+ private final static Integer STEPS_BUFFER_CAPACITY = 5000;
+
+ private BlockingQueue<ExecutionStep> steps = new ArrayBlockingQueue<ExecutionStep>(
+ STEPS_BUFFER_CAPACITY);
+
+ private Boolean hadAnError = false;
+
+ public ProcessThreadGroup(ExecutionProcess executionProcess) {
+ super("SLC Process #" + executionProcess.getUuid() + " thread group");
+ // this.executionModulesManager = executionModulesManager;
+ // this.processThread = processThread;
+ this.authentication = SecurityContextHolder.getContext()
+ .getAuthentication();