circularbuffertest.java

线程实例

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

public class CircularBufferTest extends JFrame
{
	JTextArea outputArea;
	
	public CircularBufferTest()
	{
		super("Demostrating thread Synchronized");
		
		outputArea=new JTextArea(20,30);
		outputArea.setFont(new Font("Monospaced",Font.PLAIN,12));
		getContentPane().add(new JScrollPane(outputArea));
		
		setSize(310,500);
		setVisible(true);
		
		CircularBuffer sharedLocation=new CircularBuffer(outputArea);
		
		SwingUtilities.invokeLater(new RunnableOutput(outputArea,sharedLocation.creatStateOutput()));
		
		Producer producer=new Producer(sharedLocation,outputArea);
		Consumer consumer=new Consumer(sharedLocation,outputArea);
		
		producer.start();
		consumer.start();
	}
	
	public static void main(String args[])
	{
		CircularBufferTest application=new CircularBufferTest();
		application.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
	}
	
}