producer.java

生产者 消费者

import java.util.Date;
import javax.swing.*;

public class Producer extends Thread
{
	public Producer(MessageQueue m){
		mbox = m;
	}
	
	public void run(){
		int message = 0;
		
		while (true){
			int sleeptime = (int) (Server.NAP_TIME * Math.random() );
			try{
				Thread.sleep(sleeptime*1000);
			}
			catch(InterruptedException e){}
			
			message = message +1;
			t.setText("Producer produced " + message);
			mbox.send(message);
		}
	}
	
	private MessageQueue mbox;
}