import mcmas.core.MCMCommandQueue;
import mcmas.core.MCMCommandQueueProperty;
import mcmas.core.MCMContext;
import mcmas.core.MCMDevice;
import mior.model.MiorSimulation;
import mior.model.dist.IMiorDistribution;
import mior.model.dist.LinearDistribution;


public class MiorLauncher2 extends Thread {
	
	private final int nbExecutions;
	private final MCMContext context;
	private final MCMDevice device;
	
	public MiorLauncher2(int nbExecutions, MCMContext context, MCMDevice device) {
		this.nbExecutions = nbExecutions;
		this.context = context;
		this.device = device;
	}
	
	@Override
	public void run() {
		MiorSimulation [] simulations = new MiorSimulation[nbExecutions];
		
		MCMCommandQueue queue = context.createCommandQueue(device,
				MCMCommandQueueProperty.ENABLE_PROFILING,
				MCMCommandQueueProperty.ENABLE_OOO_MODE
		);
		
		IMiorDistribution dist = new LinearDistribution(38, 310, 0.3);
		
		for (int i = 0; i < simulations.length; i++) {
			simulations[i] = new MiorSimulation(38, 310, 100, dist);
		}
		
		for (int i = 0; i < simulations.length; i++) {
			simulations[i].execute(context, queue);
		}
		
		queue.finish();
	}
	
	public static void main(String[] args) {
		final int nbThreads = 10;
		final Thread [] threads = new Thread[nbThreads];
		final MCMContext context = new MCMContext();
		
		int nbDevices = context.getDevices().length;
		
		for (int i = 0; i < nbThreads; i++) {
			threads[i] = new MiorLauncher2(10 , context, context.getDevices()[i % nbDevices]);
		}
		
		for (int i = 0; i < nbThreads; i++) {
			threads[i].start();
		}
		
		for (int i = 0; i < nbThreads; i++) {
			try {
				threads[i].join();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}