/*
 * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *         http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.argeo.slc.core.execution;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

import org.argeo.slc.execution.ExecutionModulesManager;
import org.argeo.slc.execution.ExecutionProcess;
import org.argeo.slc.execution.ExecutionStep;
import org.argeo.slc.process.SlcExecution;
import org.argeo.slc.process.SlcExecutionStep;

/** The thread group attached to a given {@link SlcExecution}. */
public class ProcessThreadGroup extends ThreadGroup {
	private final ExecutionModulesManager executionModulesManager;
	private final ProcessThread processThread;

	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()
				+ " thread group");
		this.executionModulesManager = executionModulesManager;
		this.processThread = processThread;
	}

	// public SlcExecution getSlcProcess() {
	// return processThread.getSlcProcess();
	// }

	public void dispatchAddStep(ExecutionStep step) {
		// legacy
		ExecutionProcess slcProcess = processThread.getProcess();
		if (slcProcess instanceof SlcExecution)
			((SlcExecution) slcProcess).getSteps().add((SlcExecutionStep) step);

		List<ExecutionStep> steps = new ArrayList<ExecutionStep>();
		steps.add(step);
		// dispatchAddSteps(steps);
		this.steps.add(step);
	}

	public void dispatchAddSteps(List<ExecutionStep> steps) {
		ExecutionProcess slcProcess = processThread.getProcess();
		executionModulesManager.dispatchAddSteps(slcProcess, steps);
	}

	public BlockingQueue<ExecutionStep> getSteps() {
		return steps;
	}

}