单机秒杀系统样例

public class SecKill {
    //商品数量
    private static volatile AtomicInteger count = new AtomicInteger(10);
    //商品队列
    private static Queue<String> productQueue = new ConcurrentLinkedQueue<String>();
    //用户队列
    private static Queue<String> userQueue = new ConcurrentLinkedQueue<String>();
    //用户与商品配对结果
    private static Map<String,String> userMap = new ConcurrentHashMap<String, String>();
    private static ExecutorService es = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);
    private static CountDownLatch end = new CountDownLatch(1000);
    //模拟给商品队列，用户队列添加数据
    public static void addQueue() {
        for (int i = 0;i < 1000;i++) {
            userQueue.add(Integer.toString(i));
        }
        for (int i = 0;i < 10;i++) {
            productQueue.add(Integer.toString(i + 1));
        }
    }
    public static class Kill implements Runnable {
        public void run() {
            if (count.get() > 0) {
                userMap.put(userQueue.poll(), productQueue.poll());
                count.decrementAndGet();
                System.out.println("秒杀成功");
            } else {
                System.out.println("别看了，没货了");
            }
            end.countDown();
        }
    }

    public static void main(String[] args) throws InterruptedException {
        addQueue();
        for (int i = 0;i < 1000;i++) {
            es.submit(new Kill());
        }
        end.await();
        System.out.println(count);
        for (String user:userMap.keySet()) {
            System.out.println(user + ":" + userMap.get(user));
        }
        es.shutdown();
    }
}