querythreadrep.java

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

package com.ict.netcom2.message;

import java.util.*;

public class QueryThreadRep {
	/**
	 * 当前系统线程数<br>
	 * Actually unsigned byte
	 */
	public int threadsNum;
	
	/**
	 * Thread infos
	 */
	public ArrayList<ThreadInfo> infos = 
		new ArrayList<ThreadInfo>();
	
	/**
	 * Add a ThreadInfo item to {@link #infos}
	 * @see ThreadInfo
	 * @param threadId
	 * int : 线程唯一标识ID<br>
	 * Actually unsigned int, big-endian
	 * @param taskId
	 * int : 对应 threadId 的任务唯一标识<br>
	 * Actually unsigned int, big-endian
	 */
	public void addThreadInfo(int threadId, int taskId) {
		ThreadInfo info = new ThreadInfo(threadId, taskId);
		infos.add(info);
	}
	
	public String toString() {
		StringBuffer buf = new StringBuffer("Threads information:\n");
		Iterator<ThreadInfo> it = infos.iterator();
		while (it.hasNext()) {
			buf.append(it.next().toString());
		}
		return buf.toString();
	}

}