并发队列

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

public class ConcurrentQueue {

	// 一个基于链接节点的无界线程安全队列。此队列按照 FIFO（先进先出）原则对元素进行排序。
	// 队列的头部 是队列中时间最长的元素。队列的尾部 是队列中时间最短的元素。新的元素插入到队列的尾部，队列获取操作从队列头部获得元素。当多个线程共享访问一个公共 collection
	// 时，ConcurrentLinkedQueue 是一个恰当的选择。此队列不允许使用 null 元素。

	private static ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();
	private static int count = 100; // 需要创建的线程个数

	// CountDownLatch，一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。
	private static CountDownLatch latch = new CountDownLatch(count);

	public static void main(String[] args) throws InterruptedException {
		// 比如这个方法，，一段时间执行一次。定个时什么的。。。。

		long timeStart = System.currentTimeMillis();

		// ExecutorService 提供了管理终止的方法，以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法。
		ExecutorService es = Executors.newFixedThreadPool(4);// 创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。
		ConcurrentQueue.tidan();// 提交订单
		for (int i = 0; i < count; i++) {
			// 多个进程一起收单
			es.submit(new ShouDan());// 提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。
		}
		latch.await(); // 使得主线程(main)阻塞直到latch.countDown()为零才继续执行
		System.out.println("cost time " + (System.currentTimeMillis() - timeStart) + "ms");
		es.shutdown();// 如果此执行程序已关闭，则返回 true。
	}

	/**
	 * 提交订单到队列
	 */
	public static void tidan() {
		for (int i = 0; i < 10; i++) {
			queue.offer(i);// 将指定元素插入此队列的尾部。
		}
	}

	/**
	 * 从队列取出订单做你想做的操作比如保存到数据库呀。。记录日志呀。。什么的。。。。
	 */
	static class ShouDan implements Runnable {
		public void run() {
			// while (queue.size()>0) {
			while (!queue.isEmpty()) {
				System.out.println(queue.poll());// 获取并移除此队列的头，如果此队列为空，则返回 null。
			}
			latch.countDown();// 递减锁存器的计数，如果计数到达零，则释放所有等待的线程。
		}
	}

}