Linux的五个查找命令：find,locate,whereis,which,type

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;
}
}