consumer.java

生产者 消费者

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

public class Consumer extends Thread
{
	public Consumer(MessageQueue m) {
		mbox = m;
	}
	
	public void run(){
		int message;
		
		while (true) {
			int sleeptime = (int) (Server.NAP_TIME * Math.random() );
			try{
				Thread.sleep(sleeptime*1000 );
			}
			catch(InterruptedException e){};
			
			message = (Integer)mbox.receive();
			
			if (message != -1)
				t1.setText("Consumer consumed " + message);	
			else
				t1.setText("The Queue is empty!");
			
			
		}
	}
   private MessageQueue mbox;
}