activetaskdaemon.java

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

package com.ict.netcom2.trash;

import com.ict.netcom2.message.*;
import com.ict.netcom2.task.*;
import com.ict.netcom2.net.*;
import com.ict.netcom2.result.*;

public class ActiveTaskDaemon extends Thread {

	TaskManager tm;
	Communicator2 comm;
	ResultManager2 rm;
	
	public ActiveTaskDaemon(TaskManager tm, Communicator2 comm, ResultManager2 rm) {
		this.tm = tm;
		this.comm = comm;
		this.rm = rm;
	}
	
	public void storeActiveTaskResult(String ip, TaskStatusNotify ntf) {
		Task task = tm.getTask(ntf.taskId);
		GetResultAck ack = comm.getResult(task);
		rm.storeResult(ack);
	}

}