AQS的核心思想是共享状态的管理,它通过一个int型的volatile变量来描述同步状态,同时维护一个FIFO队列,用来存放等待线程。在AQS的实现中,同步状态的修改和FIFO队列的维护是通过CAS(Compare-And-Swap)操作实现的。
当一个线程需要获取某个同步资源时,它会先尝试通过CAS操作修改同步状态,如果成功获取锁,则直接返回。
获取锁的方法取决于同步资源的类型。如果是独占资源,那么只有一个线程可以获取锁,其他线程需要等待独占锁释放。此时,获取锁的方法是通过CAS操作修改同步状态,如果成功获取锁,则返回;否则被封装为Node节点,加入到FIFO队列中等待。
如果是共享资源,多个线程可以同时获取锁,这就需要采用读写锁的机制。通过读锁可以实现多个线程同时对同一共享资源进行读操作,而写锁则是独占锁,只允许一个线程进行写操作。获取共享锁的方法是通过尝试通过CAS操作修改同步状态,并判断当前状态是否允许获取共享锁,如果成功获取锁,则返回;否则被封装为Node节点,加入到FIFO队列中等待。
如果CAS操作失败,则说明当前线程没有成功获取锁,它就会被封装为一个Node节点,并加入到FIFO队列的尾部。
如果是独占锁,节点会被加入到一个同步队列中,每个节点都有一个前驱节点和后继节点,通过这些节点连接起来形成一个FIFO队列。加入队列的方法是通过自旋操作,不断尝试将当前节点加入到队列中。如果是共享锁,则会维护两个FIFO队列,一个用来存放读锁的等待线程,另一个用来存放写锁的等待线程。
当同步状态的持有者释放锁时,它会尝试唤醒队列中的第一个线程。被唤醒的线程会再次尝试通过CAS操作获取锁,直到它成功获取锁为止。
在等待队列中,节点会有前驱和后继节点。当一个节点被唤醒并成功获取锁后,它会检查自己的后继节点是否处于等待状态。如果是,当前线程会尝试通过CAS操作获取同步状态,并将后继节点从等待队列中移除。如果获取同步状态的操作失败,说明后继节点已经被其他线程获取了锁,当前线程需要继续等待。否则,当前线程会继续尝试获取锁,如果获取成功,则返回;否则继续封装为节点加入到FIFO队列中等待。
🔔如果您需要转载或者搬运这篇文章的话,非常欢迎您私信我哦~