単純ウェブキュー

import java.util.concurrent.ArrayBlockingQueue;

/**
 *  
 * 
 * @author luoqinglong
 * @date 2014-3-23
 */
public class BuyQueue extends ArrayBlockingQueue<String>
{

	/**
	 * @param capacity
	 */
	public BuyQueue(int capacity)
	{
		super(capacity);
		// TODO Auto-generated constructor stub
	}

}

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;

/**
 *  
 * 
 * @author luoqinglong
 * @date 2014-3-23
 */
public class MemberAction
{
	/**
	 *  
	 */
	public void saveOrder(final String memberId)
	{
		// TODO INSERT DB
		try
		{
			//  
			Test.getBuyQueue().put(memberId);
		}
		catch (InterruptedException e)
		{
			e.printStackTrace();
		}
		//  
		Future<Map<String, Object>> map = Test.getExecutorService().submit(new Callable<Map<String, Object>>()
		{
			@Override
			public Map<String, Object> call() throws Exception
			{
				Map<String, Object> map = new HashMap<String, Object>();
				OrderService orderService = new OrderService();
				orderService.dealOrder();
				return map;
			}
		});

	}
}

public class OrderService
{
	/**
	 *  
	 */
	public synchronized void dealOrder()
	{
		String memberId = Test.getBuyQueue().poll();
		System.out.println(" ， ： " + memberId);
		try
		{
			//  
			Thread.sleep(1000);
		}
		catch (InterruptedException e)
		{
			e.printStackTrace();
		}
		System.out.println("--- ， ： " + memberId);
		if (Test.getBuyQueue().size() == 0)
		{
			Test.getExecutorService().shutdown();
		}
	}
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author luoqinglong
 * @date 2014-3-23
 */
public class Test
{
	private static ExecutorService executor = null;

	private static BuyQueue buyQueue = null;

	/**
	 * @param args
	 */
	public static void main(String[] args)
	{
		for (int i = 0; i < 100; i++)
		{
			MemberAction action = new MemberAction();
			action.saveOrder(i + 1 + "");
		}
	}

	public static synchronized ExecutorService getExecutorService()
	{
		if (Test.executor == null)
		{
			Test.executor = Executors.newFixedThreadPool(3);
		}
		return Test.executor;
	}

	public static synchronized BuyQueue getBuyQueue()
	{
		if (Test.buyQueue == null)
		{
			Test.buyQueue = new BuyQueue(10);
		}
		return Test.buyQueue;
	}
}