Java线程安全的有序阻塞队列PriorityBlockingQueue

﹏ヽ暗。殇╰゛Y 2024-01-20 07:34 48阅读 0赞

import java.util.Comparator;
    import java.util.Iterator;
    import java.util.concurrent.PriorityBlockingQueue;
    
    /**
     * PriorityQueue不是线程安全的。
     * PriorityBlockingQueue是阻塞式的Java线程安全队列。
     */
    
    public class Main {
    
        public static void main(String[] args) {
            try {
                new Main().test();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        private void test() throws InterruptedException {
            t();
        }
    
        private void t() throws InterruptedException {
            int capacity = 15;
    
            PriorityBlockingQueue<Integer> mQueue = new PriorityBlockingQueue(capacity, new Comparator<Integer>() {
                @Override
                public int compare(Integer i1, Integer i2) {
                    return i2 - i1;
                }
            });
    
            //随机生成10个测试数据。
            for (int i = 0; i < capacity; i++) {
                int n = (int) (Math.random() * 10);
                mQueue.add(n);
            }
    
            Iterator<Integer> iterator = mQueue.iterator();
            while (iterator.hasNext()) {
                int n = mQueue.take();
                System.out.println(n);
            }
        }
    }

输出：

8
    7
    7
    6
    6
    5
    5
    4
    4
    4
    3
    3
    3
    2
    1

发表评论取消回复

表情：

评论列表（有 0 条评论，48人围观）

还没有评论，来说两句吧...

相关阅读

相关【多线程】阻塞队列

![eccf0576596c1a839169c495d730fbc1.gif][] 1. 认识阻塞队列和消息队列阻塞队列也是一个队列，也是一个特殊的队列，也遵守先进先

川长思鸟来/ 2024年03月26日 20:10/ 0 赞/ 97 阅读

相关多线程 - 阻塞队列

阻塞队列阻塞队列是一种特殊的队列，它支持在队列为空时等待从队列中获取元素的操作，或在队列已满时等待插入元素的操作。当队列为空时，从队列中获取元素的操作会被阻塞，直

Dear 丶/ 2024年03月22日 16:23/ 0 赞/ 84 阅读

相关并发：ConcurrentLinkedQueue（非阻塞的线程安全队列）。

在并发编程中，有时候需要使用线程安全的队列。如果要实现一个线程安全的队列有两种方式：一种是使用阻塞算法，另一种是使用非阻塞算法。使用阻塞算法的队列可以用一个锁（入队和出队用同一

灰太狼/ 2024年02月19日 14:29/ 0 赞/ 23 阅读

相关 Java线程安全的有序阻塞队列PriorityBlockingQueue

import java.util.Comparator; import java.util.Iterator; import java.util.con

﹏ヽ暗。殇╰゛Y/ 2024年01月20日 07:34/ 0 赞/ 49 阅读

相关 java线程池--阻塞队列

在线程池的线程全部开启后，之后的线程任务就会先放入阻塞队列，由阻塞队列把线程任务发放到线程池的空闲线程，当阻塞队列没有任务时，线程池就会一直阻塞，直到新的线程任务进入，具体的

偏执的太偏执、/ 2023年11月02日 07:22/ 0 赞/ 157 阅读

相关多线程--阻塞队列

目录一、阻塞队列 1.阻塞队列是什么？【查看队列相关知识】 2、如何使用阻塞队列二、生产者消费者模型 1.什么是生产者消费者模型 2.生产者消费者模型是用来

青旅半醒/ 2023年09月27日 16:50/ 0 赞/ 173 阅读

相关一心多用多线程-阻塞队列（2）-PriorityBlockingQueue

二、可根据优先级自动出菜的选菜区PriorityBlockingQueue 在现实中啊，在同等同质的产品中，人们往往会选择价格低的进行购买，PriorityBlocking

た入场券/ 2022年07月15日 04:29/ 0 赞/ 243 阅读

相关一心多用多线程-阻塞队列（2）-PriorityBlockingQueue

二、可根据优先级自动出菜的选菜区PriorityBlockingQueue 在现实中啊，在同等同质的产品中，人们往往会选择价格低的进行购买，PriorityBlocking

桃扇骨/ 2022年07月15日 04:29/ 0 赞/ 201 阅读

相关多线程阻塞队列

本文讲述java自带的阻塞队列BlockingDuque。队列添加的方法有三种，add，offer，put，队列满后，如果在调用添加方法 add会抛异常，offer会

古城微笑少年丶/ 2022年07月13日 12:27/ 0 赞/ 233 阅读

相关阻塞队列（二）：PriorityBlockingQueue

阻塞队列（二）：PriorityBlockingQueue 我们知道线程Thread可以调用setPriority(int newPriority)来设置优先级的，线程优先级

短命女/ 2022年01月26日 06:53/ 0 赞/ 217 阅读