美文网首页
ProiorityBlockingQueue

ProiorityBlockingQueue

作者: 五洋捉鳖zz | 来源:发表于2020-11-06 13:50 被阅读0次

优先级队列,线程安全队列。
java

@Test
    public void priority() {
        PriorityBlockingQueue<Data> testQueue = new PriorityBlockingQueue<>();
        testQueue.offer(new Data(121234411));
        testQueue.offer(new Data(12));
        testQueue.offer(new Data(13));
        testQueue.offer(new Data(14));
        testQueue.offer(new Data(12123));
        testQueue.offer(new Data(12234));


        while (testQueue.size() > 0) {
            System.out.println(testQueue.poll().getId());
        }

    }

    @Getter
    public static class Data implements Comparable<Data>{
        private final Integer id;

        public Data(Integer id) {
            this.id = id;
        }

        @Override
        public int compareTo(Data o) {
            return o.getId().compareTo(this.getId());
        }
    }
  • output
Connected to the target VM, address: '127.0.0.1:49644', transport: 'socket'
121234411
12234
12123
14
13
12
Disconnected from the target VM, address: '127.0.0.1:49644', transport: 'socket'

Process finished with exit code 0

相关文章

网友评论

      本文标题:ProiorityBlockingQueue

      本文链接:https://www.haomeiwen.com/subject/bnjtbktx.html