consumer.java

线程实例

import javax.swing.*;

public class Consumer extends Thread
{
	private Buffer sharedLocation;
	private JTextArea outputArea;
	
	public Consumer(Buffer shared,JTextArea output)
	{
		super("Consumer");
		sharedLocation=shared;
		outputArea=output;
	}
	public void run()
	{
		int sum=0;
		
		for(int i=0;i<=10;i++)
		{
			try
			{
				Thread.sleep((int)(Math.random())*3001);
				sum+=sharedLocation.get();
			}
			catch(InterruptedException exception)
			{
				exception.printStackTrace();
			}
		}
		String name=getName();
		SwingUtilities.invokeLater(new RunnableOutput(outputArea,"\nTotal "+name+
								" consumed: "+sum+".\n"+name+" terminated.\n"));
	}
}