messagehandler.java

用java的net包写的一个小的点到点的聊天软件。用了2小时写的

package jsm;

import java.net.Socket;
import java.util.LinkedList;

public class MessageHandler {
	LinkedList receiptSockets = new LinkedList(),sendingMS = new LinkedList();

	// 保留使用
	// sendingSockets = new LinkedList(),

	Thread[] inWorkers = new DoReciever[5];

	Thread[] outWorkers = new DoSender[5];

	private static MessageHandler single = new MessageHandler();

	public static MessageHandler getMH() {
		return single;
	}

	private MessageHandler() {

	}

	public final void handleInConnection(Socket incon) {

		synchronized (receiptSockets) {
			receiptSockets.add(incon);
			receiptSockets.notify();
		}
	}

	public final void handleOutConnection(Message outms) {
		synchronized (sendingMS) {
			sendingMS.add(outms);
			sendingMS.notify();
		}
	}

	public final void initailWorkers() {
		for (int i = 0; i < inWorkers.length; i++) {
			inWorkers[i] = new DoReciever();
			outWorkers[i] = new DoSender();
			inWorkers[i].start();
			outWorkers[i].start();
		}
	}

}