Java高并发程序-Chapter3 JDK并发包（第十七讲）同步控制之ReentrantLock 的实现

ReentrantLock 的实现
1. CAS
2. 等待队列
3. park()





说明： ReentrantLock 默认使用NonfairSync 的 lock 方法



说明： NonfairSync 的 lock 方法 使用CAS ，如果某一个Thread （命名 ThreadA） 成功将stateOffset 从0变成1 （利用CPU指令集在一个事务中完成），这个线程 ThreadA 获取到当前lock（独占锁），进行线程Run执行。其他 Threads 由于 stateOffset =1 无法操作成功，必须调用 acquire 尝试获取lock。 大家奇怪stateOffset =1 ，如何还原成0呢， 当时在 unlock 方法中。






再次try acquire 获取lock， 如果不成功， 调用acquireQueued(addWaiter(Node.EXCLUSIVE), arg)
addWaiter(Node.EXCLUSIVE) 添加到Queue 队列中，这个队列通过CAS，是一个简单的无堵塞队列。








将Thread Node 添加到Queue tailer出。
 for (;;) {
            Node t = tail; // 妙笔， 必须先prev临时保存上一个tailer，然后通过CAS 完成tailer 赋值成new node，成功后可以[b]new node前插入prev
            if (t == null) { // Must initialize
                if (compareAndSetHead(new Node())) 
                    tail = head;
            } else {
                node.prev = t;
                if (compareAndSetTail(t, node)) {  //通过CAS 确认新的Node设置到tailer，如果失败，重复操作。
                    t.next = node;
                    return t;
                }
            }
        }
[/b]





通过LockSupport park 当前 Thread
unlock 方法





从 队列tailer 开始，获取 Thread Node， 必须时有效的， 从Node 取出 Thread 进行 unpark操作。