|
314
|
1 package alice.topology.manager.keeparive;
|
|
|
2
|
|
|
3 import java.util.List;
|
|
|
4
|
|
|
5 import alice.codesegment.CodeSegment;
|
|
|
6 import alice.datasegment.CommandType;
|
|
|
7 import alice.datasegment.Receiver;
|
|
|
8
|
|
|
9 public class CreateTask extends CodeSegment{
|
|
|
10 private Receiver info = ids.create(CommandType.PEEK);
|
|
|
11
|
|
|
12 public CreateTask(){
|
|
|
13 info.setKey("_CLIST");
|
|
|
14 }
|
|
|
15
|
|
|
16 @Override
|
|
|
17 public void run() {
|
|
|
18 ods.put("_WAITINGLIST", new ListManager());
|
|
|
19 @SuppressWarnings("unchecked")
|
|
|
20 List<String> list = info.asClass(List.class);
|
|
|
21
|
|
|
22 new CheckExistTask();
|
|
319
|
23 TaskExecuter.getInstance().setKey();
|
|
314
|
24 for (String manager : list){
|
|
|
25 int i = 5;
|
|
|
26 TaskInfo task = new TaskInfo(manager, "_RESPONCE", i * 1000);
|
|
|
27 ods.put("_TASKINFO", task);
|
|
|
28 i +=5;
|
|
|
29 }
|
|
|
30
|
|
|
31 }
|
|
|
32
|
|
|
33 }
|
