sender.java

3G体验手机展示程序 3G体验手机展示程序 3G体验手机展示程序

package com.hongguan.lifeshowclient2;

import java.io.*; 

public class Sender extends Thread { 

	private OutputStream os; 
	private String message; 

	public Sender(OutputStream os) { 
		this.os = os;
		start(); 
	} 

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

	public synchronized void run() { 
		while(true) { // If no client to deal, wait until one connects 
			if (message == null) { 
				try { 
					wait(); 
				} catch (InterruptedException e) { } 
			} if (message == null) { 
				break; } 

			try { 
				os.write(message.getBytes()); 
//				os.write("\r\n".getBytes()); 
			} catch (IOException ioe) { 
				ioe.printStackTrace(); 
			} // Completed client handling, return handler to pool and 
		} 
	}

/*	public final void stop() { 
		message = null;
		notify();
	} */
}