Mercurial > hg > Database > Alice
view src/alice/topology/manager/keeparive/PingScheduler.java @ 305:72739519cc39
Add Scheduler Test
author | sugi |
---|---|
date | Tue, 19 Nov 2013 15:25:45 +0900 |
parents | 366742c2b07d |
children | a8255a831ade |
line wrap: on
line source
package alice.topology.manager.keeparive; import java.util.LinkedList; import alice.codesegment.CodeSegment; public class PingScheduler extends CodeSegment{ public PingSchedList plist = new PingSchedList(); private TaskInfo nowTask; private boolean interruptFlag = false; private long INTERVAL = 60 * 1000; private long time = 0; private long postponeTime = 0; public synchronized void postpone(String name){ long elapsedTime = System.currentTimeMillis() - time; postponeTime = nowTask.getSleepTime() - elapsedTime; LinkedList<TaskInfo> list = plist.getTaskList(); if (name.equals(nowTask.getManagerKey())){ TaskInfo nextTask = list.get(0); nextTask.setSleepTime(postponeTime + nextTask.getSleepTime()); nowTask.setSleepTime(INTERVAL); plist.addTask(nowTask); } else { int cnt = 0; nowTask.setSleepTime(postponeTime); list.add(cnt, nowTask); for (TaskInfo info : list){ if (name.equals(info.getManagerKey())){ if (info != list.getLast()){ TaskInfo nextInfo = list.get(cnt+1); nextInfo.setSleepTime(nextInfo.getSleepTime() + info.getSleepTime()); } list.remove(info); info.setSleepTime(INTERVAL); plist.addTask(info); break; } cnt++; } } interruptFlag = true; notify(); } @Override public synchronized void run() { LinkedList<TaskInfo> list = plist.getTaskList(); try { while(true){ nowTask = list.poll(); System.out.print("TaskName "+nowTask.getManagerKey()); System.out.println(" sleepTime "+nowTask.getSleepTime()); time = System.currentTimeMillis(); if (nowTask.getSleepTime()!=0) this.wait(nowTask.getSleepTime()); if (interruptFlag){ interruptFlag = false; } else { //ods.put("_SENDPING", nowTask); } } } catch (InterruptedException e) { } } }