Queue 非阻塞队列

非阻塞队列

package com.test;

import java.util.LinkedList;
import java.util.PriorityQueue;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

public class LearnQueue {
    public static void main(String[] args) {
        //LinkedList 实现了双向队列 Deque,LinkedList允许添加null元素
        Queue<String> queue = new LinkedList<>();
        queue.add("x");
        queue.add(null);
        queue.offer(null);
        for (String s : queue) {
            System.out.println(s);
        }

        //Priority 可以指定初始容量，扩容方式是size<64的话，双倍扩容，>64的话1.5倍扩容
        //Priority  构造方法可以指定自定义的比较器Comparator，不指定使用元素自己的排序。
        //队列中的元素并不一定是有序的，但是队列的第一个元素肯定是优先级最高的。
        // 造成这种情况的原因是：PriorityQueue是使用最小堆实现的优先队列的存储。参考：https://blog.csdn.net/u010853261/article/details/78520960
        // 插入元素时，新增元素会与他的父节点比较，如果小于父节点则与父节点交换值，直到找到最适合他的位置。
        // 删除元素时，从0节点开始找左右最小的子节点来替换父节点，直到当前节点大于size/2
        Queue<String> priorityQueue = new PriorityQueue<>(2);
        priorityQueue.add("yello");
        priorityQueue.add("zoo");
        priorityQueue.offer("aaaa");
        //此时队列中的值为 aaaa zoo yello  (zoo 与 yello 顺序错误)
        priorityQueue.poll();
        //此时队列中的值为 yello zoo
        for (String s : priorityQueue) {
            //结果为 axzzy
            System.out.println(s);
        }

        // ConcurrentLinkedQueue 实现线程安全的方式是，
        // tail 跟head 节点是volatile修饰的，保证了可见性
        // 在修改队列时，调用了 UNSAFE.compareAndSwapObject() 保证了该操作的原子性
        // 关于CAS的解释：https://juejin.im/post/5a73cbbff265da4e807783f5
        Queue<String> concurrentLinkedQueue = new ConcurrentLinkedQueue<>();
        concurrentLinkedQueue.add("xxx");
    }
}