Treiber Stack简单分析

拼搏现实的明天。 2023-06-13 11:13 7阅读 0赞

Abstract

Treiber Stack Algorithm是一个可扩展的无锁栈，利用细粒度的并发原语CAS来实现的，Treiber Stack在 R. Kent Treiber在1986年的论文Systems Programming: Coping with Parallelism中首次出现。

基本原理

该算法的基本原理是：只有当您知道要添加的项目是自开始操作以来唯一添加的项目时，才会添加新的项目。 这是通过使用比较和交换完成的。 在添加新项目时使用堆栈，将堆栈的顶部放在新项目之后。 然后，将这个新构造的头元素（旧头）的第二个项目与当前项目进行比较。 如果两者匹配，那么你可以将旧头换成新头，否则就意味着另一个线程已经向堆栈添加了另一个项目，在这种情况下，你必须再试一次。

当从堆栈中弹出一个项目时，在返回项目之前，您必须检查另一个线程自操作开始以来没有添加其他项目。

正确性

在某些语言中，特别是那些没有垃圾回收的语言，Treiber栈可能面临ABA问题。当一个进程要从堆栈中移除一个元素时（就在下面的pop例程比较和设置之前），另一个进程可以改变堆栈，使得头部是相同的，但是第二个元素是不同的。比较和交换将堆栈的头部设置为堆栈中旧的第二个元素，混合完整的数据结构。但是，由于Java运行时提供了更强大的保证，所以此页面上的Java版本不受此问题的影响（新创建的不混淆的对象引用不可能与任何其他可到达的对象引用相同）。

对诸如ABA之类的故障进行测试可能会非常困难，因为有问题的事件序列非常少见。

Java示例

下面是Java中Treiber Stack的实现，它基于Java Concurrency in Practice提供的

public class ConcurrentStack<E> {
        private AtomicReference<Node<E>> top = new AtomicReference<>();
    
        public void push(E item) {
            Node<E> newHead = new Node<>(item);
            Node<E> oldHead;
            do {
                oldHead = top.get();
                newHead.next = oldHead;
            } while (!top.compareAndSet(oldHead, newHead));
        }
    
        public E pop() {
            Node<E> oldHead;
            Node<E> newHead;
            do {
                oldHead = top.get();
                if (oldHead == null)
                    return null;
                newHead = oldHead.next;
            } while (!top.compareAndSet(oldHead, newHead));
            return oldHead.item;
        }
    
        private static class Node<E> {
            public final E item;
            public Node<E> next;
            public Node(E item) {
                this.item = item;
            }
        }
    }

流程分析

PUSH操作

![图片描述][format_png]  
根据上述的描述做图如上，并分析其工作流程。

1.  首先单链表保存了各个Stack中的各个元素，成员变量top持有了栈的栈顶元素。
2.  当执行push操作时，首先创建一个新的元素为`newHead`，并让该新节点的`next`指针指向`top`节点（此时`top=oldHead`）。
3.  最后通过CAS替换`top=newHead`，CAS的交换条件是`top=oldHead`。
4.  当条件满足后，操作后的状态如下：

![图片描述][format_png 1]

POP操作

![图片描述][format_png 2]  
根据上述的描述做图如上，并分析其工作流程。

1.  当执行pop操作时，创建一个新的指针，该指针指向`top`的`next`元素。
2.  然后通过CAS替换`top=newHead`，CAS的交换条件是`top=oldHead`。

3.当条件满足后，操作后的状态如下：  
![图片描述][format_png 3]

PS:

java.util.concurrent.FutureTask中waiters就使用了Treiber Stack

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9zZWdtZW50ZmF1bHQuY29tL2ltZy9iVjBzdFY?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9zZWdtZW50ZmF1bHQuY29tL2ltZy9iVjBzdkQ?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9zZWdtZW50ZmF1bHQuY29tL2ltZy9iVjBzdjk?x-oss-process=image/format,png
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9zZWdtZW50ZmF1bHQuY29tL2ltZy9iVjBzd3g?x-oss-process=image/format,png