package alice.test.concurrent;

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

public class AliceFinish extends CodeSegment {

    private int num;

    public Receiver ds1 = ids.create(CommandType.TAKE);

    public AliceFinish(int threadNum) {
        this.num = threadNum;
    }

    @Override
    public void run() {
        if (--num == 0) System.exit(0);

        AliceFinish cs1 = new AliceFinish(num);
        cs1.ds1.setKey("finish", this);
    }

}