resultmanager2.java

利用Java Socket写的一段通讯协议

package com.ict.netcom2.result;

import java.io.Serializable;
import java.util.*;
import com.ict.netcom2.message.*;
import com.ict.netcom2.task.*;


public class ResultManager2 {
	
	HashMap<Integer,MeasureResult> results;
	SysInfo sysInfo;
	ArrayList<TaskInfo> readyTasks;
	ArrayList<TaskInfo> runningTasks;
	ArrayList<ThreadInfo> threadInfos;	
	
	public ResultManager2() {
		results = new HashMap<Integer,MeasureResult>();
	}
	
	public void storeResult(GetResultAck ack) {
		if (ack.status != 0) {
			System.out.println(ack.reportStatus());
			return;
		}
		results.put(ack.result.taskId, ack.result);
	}
	
	public void storeSysInfo(SysInfo info) {
		sysInfo = info;
	}
	
	public void storeTaskInfo(QueryTaskRep rep) {
		if (rep.taskListType == TaskListType.READY) {
			readyTasks = rep.tasks;
		}
		else if (rep.taskListType == TaskListType.RUNNING) {
			runningTasks = rep.tasks;
		}
	}
	
	public void storeThreadInfo(QueryThreadRep rep) {
		threadInfos = rep.infos;
	}
	
	
	public MeasureResult getResult(int taskId) {
		return results.get(taskId);
	}
	
	public ArrayList<TaskInfo> getReadyTasks() {
		return readyTasks;
	}
	
	public ArrayList<TaskInfo> getRunningTasks() {
		return runningTasks;
	}
	
	public ArrayList<ThreadInfo> getThreadInfos() {
		return threadInfos;
	}
	
	public SysInfo getSysInfo() {
		return sysInfo;
	}
	
	

}