receiver.java

来自「本程序是一个基于RMI的聊天室,使用了多线程,事件模型,支持多用户同时登陆」· Java 代码 · 共 30 行

import javax.swing.*;
public class Receiver implements MessageListener,Runnable {
	private Thread iThread;
	private boolean iHaveMessage=false;
	public Receiver(){
		iThread=new Thread(this);
		iThread.start();
	}
	public void run(){
         while(true){
		if(iHaveMessage==true){
			System.out.println("ok");
		    
			synchronized(this){
		    	iHaveMessage=false;
		    }
			iThread.suspend();
		}
		}
	}
public synchronized void MessageStatus(MessageEvent event){
	if(iHaveMessage==false){
		
		iHaveMessage=true;
		iThread.resume();
		}
}
}