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();// 递减锁存器的计数,如果计数到达零,则释放所有等待的线程。 } } }
并发队列
猜你喜欢
转载自xiaoliang330.iteye.com/blog/2261421
今日推荐
周排行