并發(fā)之AQS原理(一)

如果說每一個(gè)同步的工具各有各的強(qiáng)大，那么這個(gè)強(qiáng)大背后是一個(gè)相同的動(dòng)力，它就是AQS.

AQS是什么

AQS是指java.util.concurrent.locks包里的AbstractQueuedSynchronizer類，抽象的FIFO隊(duì)列式的同步器，AQS定義了一套多線程訪問共享資源的同步器框架

在了解AQS之前先了解下

先入先出隊(duì)列(First Input First Output，FIFO)這是一種傳統(tǒng)的按序執(zhí)行方法，先進(jìn)入的指令先完成并引退，跟著才執(zhí)行第二條指令。

就是通常情況下的排隊(duì)。

AQS簡(jiǎn)單的來說就是使用了一個(gè)共享變量來同步狀態(tài)，該狀態(tài)由子類去維護(hù)，而AQS框架做的是

• 線程阻塞隊(duì)列的維護(hù)。
• 線程阻塞和喚醒。
  共享變量的操作通過Unsafe類提供的CAS操作完成的。AQS類主要使用的就是2個(gè)方法 acquire、release。

acquire(獲得鎖)：返回true則放線程成繼續(xù)執(zhí)行，否則將線程加入等待隊(duì)列中，等待喚醒.

release(釋放鎖)：用于釋放鎖。釋放當(dāng)前線程隊(duì)列中的頭結(jié)點(diǎn)，然后調(diào)用喚醒下一個(gè)結(jié)點(diǎn)的方法。

AQS的簡(jiǎn)單使用

一般的來說AQS的使用方式是繼承，用的是模板方法模式。

下面我們來用一個(gè)簡(jiǎn)單的AQS實(shí)現(xiàn)來逐步講解下AQS的原理。

EasyLock簡(jiǎn)單實(shí)現(xiàn)AQS

首先實(shí)現(xiàn)一個(gè)簡(jiǎn)單的鎖就叫EasyLock吧

/*** 簡(jiǎn)單不可重入鎖實(shí)現(xiàn)**/ public class EasyLock extends AbstractQueuedSynchronizer {/*** 鎖定*/public void lock(){acquire(1);}/*** 嘗試鎖定*/public boolean tryLock(){return tryAcquire(1);}/*** 解鎖*/public void unlock(){release(1);}/*** 是否為鎖定*/public boolean isLocked(){return isHeldExclusively();}/*** 嘗試獲取鎖*/@Overrideprotected boolean tryAcquire(int arg) {if(compareAndSetState(0,1)){setExclusiveOwnerThread(Thread.currentThread());return true;}return false;}/*** 嘗試釋放鎖*/@Overrideprotected boolean tryRelease(int arg) {setExclusiveOwnerThread(null);setState(0);return true;} }

測(cè)試

public class AqsExampleDemo {private static final int clientTotal = 30000;private static int count = 0;public static void main(String[] args) throws InterruptedException {final EasyLock easyLock = new EasyLock();ExecutorService executorService = Executors.newCachedThreadPool();CountDownLatch countDownLatch = new CountDownLatch(clientTotal);for (int i = 0; i < clientTotal; i++) {executorService.execute(() -> {try {easyLock.lock();count++;easyLock.unlock();} catch (Exception e) {e.printStackTrace();}countDownLatch.countDown();});}countDownLatch.await();System.out.println("統(tǒng)計(jì)次數(shù)：" + count);} }

可以看出打印的結(jié)果是5000，并沒有出現(xiàn)并發(fā)問題。

總結(jié)

可以看出AQS的使用非常簡(jiǎn)單幾乎只需要重寫 tryAcquire、tryRelease就可以自己實(shí)現(xiàn)一個(gè)鎖。
下一篇我們講解下AQS中底層的CLH隊(duì)列是如何保證其并發(fā)性的。

轉(zhuǎn)載于:https://www.cnblogs.com/yanlong300/p/9772271.html

總結(jié)

以上是生活随笔為你收集整理的并发之AQS原理(一) 原理介绍简单使用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。