package alice.test.topology.share;

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

public class AutoIncrement extends CodeSegment {

    public Receiver position = ids.create(CommandType.PEEK);

    public AutoIncrement(String key){
        this.position.setKey(key, this);
    }

    @Override
    public void run() {
        synchronized(this){
            try {
                wait(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        ods.update(position.key, new DataInfo(System.nanoTime()));
        new AutoIncrement(position.key);
    }

}