具有offer和flush的非阻塞并发队列

Question

具有offer和flush的非阻塞并发队列

我需要一个基本上只有2个操作的无界非阻塞并发队列：

• 提供：在此队列的尾部自动插入指定项；
• flush：获取队列中在该时刻出现的所有项，并开始按照插入顺序逐一处理它们。更具体地说，必须是原子的只是这个“TakeAll”操作，它将是flush的第一个操作。takeAll之后提供给队列的所有项都将被插入，然后仅由另一个后续刷新处理。

目标是使用者在takeAll上有一个CAS操作，然后可以迭代列表中的元素，而不需要每次读取都经历CAS操作。此外，我们已经拥有了节点（条目），因为它需要存储一些其他不可变的状态。新节点可以将HEAD作为构造函数参数，从而创建一个单向链表。

文学中是否存在具有这些特征的队列？

Answer 1

给你：

public class FunkyQueue<T> {
    private final AtomicReference<Node<T>> _tail = new AtomicReference<Node<T>>();

    public void offer(T t) {
        while(true) {
            Node<T> tail = _tail.get();
            Node<T> newTail = new Node<T>(t, tail);
            if(_tail.compareAndSet(tail, newTail)) {
                break;
            }
        }
    }

    public List<T> takeAll() {
        Node<T> tail = _tail.getAndSet(null);

        LinkedList<T> list = new LinkedList<T>();
        while(tail != null) {
            list.addFirst(tail.get());
            tail = tail.getPrevious();
        }

        return list;
    }

    private static final class Node<T>
    {
        private final T _obj;
        private Node<T> _prev;

        private Node(T obj, Node<T> prev) {
            _obj = obj;
            _prev = prev;            
        }

        public T get() {
            return _obj;
        }

        public Node<T> getPrevious() {
            return _prev;
        }
    }
}