view src/test/java/alice/daemon/ReceiveInteger.java @ 508:b7d02ea79850 dispose

change multicast Data Segment API
author sugi
date Sun, 04 Jan 2015 13:51:01 +0900
parents
children 15eeb439830c
line wrap: on
line source

package alice.daemon;

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

public class ReceiveInteger extends CodeSegment{

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

    @Override
    public void run() {
        int num = this.num.asInteger();
        System.out.println("[CodeSegment] "+num);

        if (num==10) {
            ods.put("multicast1", "str", "finish");
            try {
                synchronized (this) {
                    wait(2000);
                }
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.exit(0);
        }
        ReceiveInteger cs = new ReceiveInteger();
        cs.num.setKey("num");

    }

}