server.java

生产者 消费者

import javax.swing.*;
import java.awt.*;
import java.awt.event.*;

public class Server extends JApplet{
	
	static JTextField t3= new JTextField(20);
	static JTextField t = new JTextField(20);
	static JTextField t2= new JTextField(20);
	
 static JTextField t1 = new JTextField(20);
	
	private JButton
	start = new JButton("Start1"),
	resum = new JButton("Ressume1"),
	onOff = new JButton("Suspend1"),
	stopS = new JButton("Stop1"),
	
	start2 = new JButton("Start2"),
	resum2 = new JButton("Ressume2"),
	onOff2 = new JButton("Suspend2"),
	stopS2 = new JButton("Stop2");
	
	//******************************************************************************
	
	class StartL implements ActionListener {
		public void actionPerformed(ActionEvent e){
			if (!producerT.isAlive()){
				producerT = new Producer(mailBox);
				producerT.start();
				}
			t1.setText("Start Producer1");
		}
	}
	
	class Resum implements ActionListener{
		public void actionPerformed(ActionEvent e){
			producerT.resume();
			t1.setText("Resume Producer1");
				}
		}

	
	class OnOffL implements ActionListener {
		public void actionPerformed(ActionEvent e){
			producerT.suspend();
			t1.setText("Suspend Producer1");
		}
	}
	
	class stopL implements ActionListener {
		public void actionPerformed(ActionEvent e){
			producerT.stop();
			t1.setText("Stop Producer1");
		}
	}
	
//***********************************************************************************
	
	class StartL2 implements ActionListener {
		public void actionPerformed(ActionEvent e){
			if (!consumerT.isAlive()){
				consumerT = new Consumer(mailBox);
				consumerT.start();
				}
			t1.setText("Start Consumer2");
		}
	}
	
	class Resum2 implements ActionListener{
		public void actionPerformed(ActionEvent e){
			consumerT.resume();
			t1.setText("Resume Consumer2");
				}
		}

	
	class OnOffL2 implements ActionListener {
		public void actionPerformed(ActionEvent e){
			consumerT.suspend();
			t1.setText("Suspend Consumer2");
		}
	}
	
	class stopL2 implements ActionListener {
		public void actionPerformed(ActionEvent e){
			consumerT.stop();
			t1.setText("Stop Consumer2");
		}
	}
	
	//*************************************************************************
	
	public void init(){
		Container cp = getContentPane();
		
		cp.setLayout(new FlowLayout());
		cp.add(t3);
		cp.add(t);
		cp.add(t2);
		
		start.addActionListener(new StartL());
		cp.add(start);
		onOff.addActionListener(new OnOffL());
		cp.add(onOff);
		resum.addActionListener(new Resum());
		cp.add(resum);
		stopS.addActionListener(new stopL());
		cp.add(stopS);
		
		start2.addActionListener(new StartL2());
		cp.add(start2);
		onOff2.addActionListener(new OnOffL2());
		cp.add(onOff2);
		resum2.addActionListener(new Resum2());
		cp.add(resum2);
		stopS2.addActionListener(new stopL2());
		cp.add(stopS2);
		
		cp.add(t1);
	}
	
	private MessageQueue mailBox = new MessageQueue();
	private Producer producerT = new Producer(mailBox);
	private Consumer consumerT = new Consumer(mailBox);
	public static final int NAP_TIME = 5;
	
	
}