package alice.test.concurrent;

import org.msgpack.type.ValueFactory;

import alice.codesegment.CodeSegment;

public class StartConcurrent extends CodeSegment {

	private int count;
	
	public StartConcurrent(int count) {
		this.count = count;
	}

	@Override
	public void run() {
		int threadNum = Runtime.getRuntime().availableProcessors() * count;
		
		AliceFinish cs1 = new AliceFinish(threadNum);
		cs1.ds1.setKey("finish");
		
		for (int i = 0; i < threadNum; i++) {
			SleepCodeSegment cs2 = new SleepCodeSegment(i);
			cs2.ds1.setKey("wait");
		}
		
		for (int i = 0; i < threadNum; i++) {
			ods.put("local", "wait", ValueFactory.createNilValue());
		}
	}
	
}