sender.java

来自「Java ME手机应用开发大全一书的配套光盘上的源码」· Java 代码 · 共 50 行

import javax.microedition.midlet.*;
import javax.microedition.io.*;
import javax.microedition.lcdui.*;
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
// mark for wait
message = null;
}
}

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