Mercurial > hg > Database > Alice
view src/alice/topology/manager/keeparive/TaskExecuter.java @ 319:89dc953fd9e8
Chanage Class namae
author | one |
---|---|
date | Tue, 17 Dec 2013 17:21:12 +0900 |
parents | src/alice/topology/manager/keeparive/SendPing.java@32d033a4b3c7 |
children | aafc88985822 |
line wrap: on
line source
package alice.topology.manager.keeparive; import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; import alice.datasegment.Receiver; public class TaskExecuter extends CodeSegment{ private Receiver info = ids.create(CommandType.TAKE); private TaskInfo nowTask; private boolean interruptFlag = false; private long time = 0; private static TaskExecuter instance = new TaskExecuter(); private TaskExecuter(){} public static TaskExecuter getInstance() { return instance; } public void setKey(){ ids.init(); info.setKey("_WAITINGLIST"); } @Override public synchronized void run() { ListManager list = info.asClass(ListManager.class); if (list.getTaskList().size() == 0){ ods.update("_WAITINGLIST", list); setKey(); return; } else { try { nowTask = list.getTaskList().poll(); ods.update("_WAITINGLIST", list); time = System.currentTimeMillis(); if (nowTask.getSleepTime()!=0) this.wait(nowTask.getSleepTime()); if (interruptFlag){ interruptFlag = false; } else { ods.ping(nowTask.getManagerKey(), nowTask.getReturnKey()); new RespondPing(nowTask.getReturnKey()); } } catch (InterruptedException e) { } } setKey(); } public synchronized void interrupt(){ interruptFlag = true; notify(); } public TaskInfo getNowTask() { return nowTask; } public long getTime(){ return time; } }