赞
踩
最近在以ReentrantLock为例研究aqs的源码实现,以下介绍一下自己的心得,以及简单手写一个ReentrantLock锁类,加深对ReentrantLock的原理了解。
ReentrantLock是java中最常见的锁,ReentrantLock是利用AQS队列+CAS+
LockSupport来实现的,它是一种独占锁、可重入锁,它支持公平锁和非公平锁模式。
AbstractQueuedSynchronizer(AQS),类如其名,抽象的队列式的同步器,AQS定义了一套多线程访问共享资源的同步器框架,许多同步类实现都依赖于它,如常用的ReentrantLock/Semaphore/CountDownLatch。
了解AQS实现原理有助于我们理解其他并发工具类。本文不注重探究ReentrantLock源码实现原理(下篇文章再来探究源码),以手写锁类来揭示
ReentrantLock实现思想,尽量保持方法名与源码方法一致,方便同学们对照源码学习,本文只是简单实现,源码比较复杂的设计就一一略过了,有兴趣的同学可以参照源码研究。
package com.argus.aqs.aqsdemo; import java.util.concurrent.ConcurrentLinkedDeque; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.locks.LockSupport; /** * @description: 手写reentrantlock * @author: argus * @date: Created in 2023/3/15 15:46 * @version: 1.0.0 * @modified By: */ public class ArgusLock { private final ArgusSync sync; public ArgusLock(){ sync = new nonfailArgusSync(); } public ArgusLock(boolean fail){ sync= fail ? new failArgusSync() : new nonfailArgusSync(); } public void lock(){ sync.lock(); } public void unlock(){ sync.release(1); } static abstract class ArgusSync{ //cas 控制锁状态 0没有线程占用 1 被线程专用 private AtomicInteger atomicInteger = new AtomicInteger(0); //没有获取锁的线程存放队列 private ConcurrentLinkedDeque<Thread> concurrentLinkedDeque = new ConcurrentLinkedDeque<>(); //当前锁持有线程 private transient Thread exclusiveOwnerThread; private transient Thread headThread; protected void setExclusiveOwnerThread(Thread thread){ exclusiveOwnerThread = thread; } protected Thread getExclusiveOwnerThread(){ return exclusiveOwnerThread; }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。