view src/alice/topology/manager/keeparive/ListManager.java @ 324:806cc010a5bd

remove enqueue bug.
author one
date Tue, 24 Dec 2013 18:30:13 +0900
parents f1cd920ea913
children 54d0b947079a
line wrap: on
line source

package alice.topology.manager.keeparive;

import java.util.LinkedList;

public class ListManager {
	private LinkedList<TaskInfo> list = new LinkedList<TaskInfo>();
	
	public LinkedList<TaskInfo> getTaskList(){
		return list;
	}
		
	public void addTask(TaskInfo newInfo){
		TaskExecuter exec = TaskExecuter.getInstance();
		
		if (list.isEmpty()) {
			if (exec.getNowTask() == null){ // active task is nothing
				list.add(newInfo);
			} else {
				TaskInfo nowTask = exec.getNowTask();
				long remainingTime = nowTask.getSleepTime() - (System.currentTimeMillis() - exec.getTime());
				if (remainingTime < newInfo.getSleepTime()){
					// newTask is longer than active task.
					newInfo.setSleepTime(remainingTime - newInfo.getSleepTime());
					list.add(newInfo);
				} else {
					// active task is longer than newTask. 
					list.add(nowTask);
					addTask(newInfo);
				}
			}
		} else {
			int cnt = 0;
			for (TaskInfo info : list){
				if (info.getSleepTime() < newInfo.getSleepTime()){
					newInfo.setSleepTime(newInfo.getSleepTime() - info.getSleepTime());	
				} else if (info.getSleepTime() == newInfo.getSleepTime()){
					// newInfo.getSleepTime() - info.getSleepTime() must be Zero
					newInfo.setSleepTime(newInfo.getSleepTime() - info.getSleepTime());
					cnt++;
					break;
				} else if (info.getSleepTime() > newInfo.getSleepTime()){
					info.setSleepTime(info.getSleepTime() - newInfo.getSleepTime());
					break;
				}
				cnt++;
			}
			list.add(cnt, newInfo);
		}
	}
	
	
}