package alice.test.concurrent;

import org.msgpack.type.ValueFactory;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;

public class SleepCodeSegment extends CodeSegment {

	public Receiver ds1 = ids.create(CommandType.TAKE);
	
	private int num;
	
	public SleepCodeSegment(int i) {
		this.num = i;
	}

	@Override
	public void run() {
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("[CodeSegment-" + num + "] Hello, World!");
		
		ods.put("local", "finish", ValueFactory.createNilValue());
	}

}