BlockingQueue阻塞队列的例子

package com.test;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class BlockingQueueTest
{

	/**
	 * @param args
	 */
	public static void main(String[] args)
	{
		ExecutorService pool = Executors.newCachedThreadPool();

		final BlockingQueue bq = new ArrayBlockingQueue(3);

		for (int i = 0; i < 2; i++)
		{
			pool.execute(new Runnable()
			{
				public void run()
				{
					try
					{
						while (true)
						{
							Thread.sleep(new Random().nextInt(1000));
							System.out.println(Thread.currentThread().getName()
									+ "准备放数据");
							bq.put(1);
							System.out.println(Thread.currentThread().getName()
									+ "已经放完数据,目前队列有"+bq.size()+"个数据");
						}
					}
					catch (InterruptedException e)
					{
						e.printStackTrace();
					}
				}
			});
		}
		
		pool.execute(new Runnable()
		{
			public void run()
			{
				try
				{
					while (true)
					{
						Thread.sleep(100);
						System.out.println(Thread.currentThread().getName()
								+ "准备取数据");
						bq.take();
						System.out.println(Thread.currentThread().getName()
								+ "已经取走数据,目前队列有"+bq.size()+"个数据");
					}
				}
				catch (InterruptedException e)
				{
					e.printStackTrace();
				}
			}
		});
	}

}