sender.java

J2ME开发的手机socket 聊天室源码。

package server;

/*********************************************Sender**************************/
import java.io.*;

public class Sender extends Thread {
	private DataOutputStream dos;

	private String message;

	public Sender(DataOutputStream os) {
		dos = os;
		start();
	}

	public synchronized void send(String msg) {
		message = msg;
		notify();
	}

	public synchronized void run() {

		while (true) {
			if (message == null)
				try {
					wait();
				} catch (InterruptedException e) {
				}

			if (message == null)
				break;

			try {
				dos.writeChars(message);
				dos.writeChars("\r\n");
			} catch (IOException ioe) {
				try {
					ServerMain.removeObject(this);
				} catch (Exception ex) {
				}
			}
			message = null;
		}
	}

	public synchronized void stop1() {
		message = null;
		notify();
	}
}