分散フレームワークChristieの設計 |
照屋のぞみ
- profile not found -
|
public class TestCodeSegment extends CodeSegment {
private Receiver input = ids.create(CommandType.TAKE);
public TestCodeSegment() {
input.setKey("count");
}
@Override
public void run() {
int count = input.asClass(Integer.class);
System.out.println("data = " + count);
new TestCodeSegment();
ods.put("count", count);
}
}
put("compressedRemoteDGM", "key", data)
class TestCG extends CodeSegment{
private Receiver input1;
private Receiver input2;
public TestCG() {
input1 = ids.create(CommandType.TAKE);
input1.setKey("hoge");
input2 = ids.create(CommandType.TAKE);
input2.setKey("huga");
}
}
@Take(”count”)
public DataGear<Integer> count = new DataGear<>();
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Take {
String value();
}
@Take(”count”)
public DataGear<Integer> count = new DataGear<>();
@RemoteTake(dgmName="remote", key=”count”)
public DataGear<Integer> count = new DataGear<>();
cgm.setup(new TestCodeGear());
@Take(”count”)
public DataGear<Integer> count = new DataGear<>();
public class GetData extends CodeGear{
@Take(”name”)
public DataGear<String> name = new DataGear<>();
@Override
protected void run(CodeGearManager cgm) {
System.out.println(”this name is : ” + name.getData());
}
}
akka://mySystem/user/supervisorActor/childActor