buffertest.java

jsp+javabean+servlet实现的在线书店

package thread;
public class BufferTest {

	volatile boolean running=true;
	BoundedBuffer buffer=new BoundedBuffer();
	private int n=0;
	public void run()
	{
		Thread t1=new Thread(new PutThread());
		Thread t2=new Thread(new TakeThread());
		t1.start();
		t2.start();					
			try {
				t1.join();
				t2.join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}		
		
	}
	private class PutThread implements Runnable
	{
		@Override
		public void run() {
			try
			{
				while(running)
				{
					buffer.put(n++);
					if(n>100)
						running=false;
					
				}
			}
			catch(InterruptedException e)
			{
				//e.printStackTrace();
			}
		}		
	}
	private class TakeThread implements Runnable
	{
		@Override
		public void run() {
			try
			{
				while(running)
				{
					buffer.take();		
					
				}
			}
			catch(InterruptedException e)
			{
				//e.printStackTrace();
			}
		}		
	}
}