av激情亚洲男人的天堂国语,日韩欧美精品一中文字幕,无码av一区二区三区无码,国产又色又爽又刺激的a片,国产又色又爽又刺激的a片

基礎(chǔ)篇：Java原子組件和同步組件

本文轉(zhuǎn)載自微信公眾號(hào)「潛行前行」，作者cscw 。轉(zhuǎn)載本文請(qǐng)聯(lián)系潛行前行公眾號(hào)。

成都創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站制作、做網(wǎng)站與策劃設(shè)計(jì),涇縣網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十余年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:涇縣等地區(qū)。涇縣做網(wǎng)站價(jià)格咨詢:18982081108

 前言

在使用多線程并發(fā)編程的時(shí)，經(jīng)常會(huì)遇到對(duì)共享變量修改操作。此時(shí)我們可以選擇ConcurrentHashMap，ConcurrentLinkedQueue來(lái)進(jìn)行安全地存儲(chǔ)數(shù)據(jù)。但如果單單是涉及狀態(tài)的修改，線程執(zhí)行順序問(wèn)題，使用Atomic開(kāi)頭的原子組件或者ReentrantLock、CyclicBarrier之類的同步組件，會(huì)是更好的選擇，下面將一一介紹它們的原理和用法

  • 原子組件的實(shí)現(xiàn)原理CAS
  • AtomicBoolean、AtomicIntegerArray等原子組件的用法、
  • 同步組件的實(shí)現(xiàn)原理
  • ReentrantLock、CyclicBarrier等同步組件的用法

原子組件的實(shí)現(xiàn)原理CAS

  • cas的底層實(shí)現(xiàn)可以看下之前寫的一篇文章:詳解鎖原理，synchronized、volatile+cas底層實(shí)現(xiàn)[1]

應(yīng)用場(chǎng)景

  • 可用來(lái)實(shí)現(xiàn)變量、狀態(tài)在多線程下的原子性操作
  • 可用于實(shí)現(xiàn)同步鎖(ReentrantLock)

原子組件

  • 原子組件的原子性操作是靠使用cas來(lái)自旋操作volatile變量實(shí)現(xiàn)的
  • volatile的類型變量保證變量被修改時(shí)，其他線程都能看到最新的值
  • cas則保證value的修改操作是原子性的，不會(huì)被中斷

基本類型原子類

 
 
 
    
  
  
  
  1. AtomicBoolean //布爾類型 
    2.   
  
  
  2. AtomicInteger //正整型數(shù)類型 
    3.   
  
  
  3. AtomicLong   //長(zhǎng)整型類型 
    4.

使用示例

 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     AtomicBoolean atomicBoolean = new AtomicBoolean(false); 
    3.   
  
  
  3.     //異步線程修改atomicBoolean 
    4.   
  
  
  4.     CompletableFuture future = CompletableFuture.runAsync(() ->{ 
    5.   
  
  
  5.         try { 
    6.   
  
  
  6.             Thread.sleep(1000); //保證異步線程是在主線程之后修改atomicBoolean為false 
    7.   
  
  
  7.             atomicBoolean.set(false); 
    8.   
  
  
  8.         }catch (Exception e){ 
    9.   
  
  
  9.             throw new RuntimeException(e); 
    10.   
  
  
  10.         } 
    11.   
  
  
  11.     }); 
    12.   
  
  
  12.     atomicBoolean.set(true); 
    13.   
  
  
  13.     future.join(); 
    14.   
  
  
  14.     System.out.println("boolean value is:"+atomicBoolean.get()); 
    15.   
  
  
  15. } 
    16.   
  
  
  16. ---------------輸出結(jié)果------------------ 
    17.   
  
  
  17. boolean value is:false 
    18.

引用類原子類

 
 
 
    
  
  
  
  1. AtomicReference 
    2.   
  
  
  2. //加時(shí)間戳版本的引用類原子類 
    3.   
  
  
  3. AtomicStampedReference 
    4.   
  
  
  4. //相當(dāng)于AtomicStampedReference，AtomicMarkableReference關(guān)心的是 
    5.   
  
  
  5. //變量是否還是原來(lái)變量，中間被修改過(guò)也無(wú)所謂 
    6.   
  
  
  6. AtomicMarkableReference 
    7.
  • AtomicReference的源碼如下，它內(nèi)部定義了一個(gè)volatile V value，并借助VarHandle(具體子類是FieldInstanceReadWrite)實(shí)現(xiàn)原子操作，MethodHandles會(huì)幫忙計(jì)算value在類的偏移位置，最后在VarHandle調(diào)用Unsafe.public final native boolean compareAndSetReference(Object o, long offset, Object expected, Object x)方法原子修改對(duì)象的屬性
 
 
 
    
  
  
  
  1. public class AtomicReference implements java.io.Serializable { 
    2.   
  
  
  2.     private static final long serialVersionUID = -1848883965231344442L; 
    3.   
  
  
  3.     private static final VarHandle VALUE; 
    4.   
  
  
  4.     static { 
    5.   
  
  
  5.         try { 
    6.   
  
  
  6.             MethodHandles.Lookup l = MethodHandles.lookup(); 
    7.   
  
  
  7.             VALUE = l.findVarHandle(AtomicReference.class, "value", Object.class); 
    8.   
  
  
  8.         } catch (ReflectiveOperationException e) { 
    9.   
  
  
  9.             throw new ExceptionInInitializerError(e); 
    10.   
  
  
  10.         } 
    11.   
  
  
  11.     } 
    12.   
  
  
  12.     private volatile V value; 
    13.   
  
  
  13.     .... 
    14.

ABA問(wèn)題

  • 線程X準(zhǔn)備將變量的值從A改為B，然而這期間線程Y將變量的值從A改為C，然后再改為A;最后線程X檢測(cè)變量值是A，并置換為B。但實(shí)際上，A已經(jīng)不再是原來(lái)的A了
  • 解決方法，是把變量定為唯一類型。值可以加上版本號(hào)，或者時(shí)間戳。如加上版本號(hào)，線程Y的修改變?yōu)锳1->B2->A3，此時(shí)線程X再更新則可以判斷出A1不等于A3
  • AtomicStampedReference的實(shí)現(xiàn)和AtomicReference差不多，不過(guò)它原子修改的變量是volatile Pair pair;，Pair是其內(nèi)部類。AtomicStampedReference可以用來(lái)解決ABA問(wèn)題 
 
 
 
    
  
  
  
  1. public class AtomicStampedReference { 
    2.   
  
  
  2.     private static class Pair { 
    3.   
  
  
  3.         final T reference; 
    4.   
  
  
  4.         final int stamp; 
    5.   
  
  
  5.         private Pair(T reference, int stamp) { 
    6.   
  
  
  6.             this.reference = reference; 
    7.   
  
  
  7.             this.stamp = stamp; 
    8.   
  
  
  8.         } 
    9.   
  
  
  9.         static  Pair of(T reference, int stamp) { 
    10.   
  
  
  10.             return new Pair(reference, stamp); 
    11.   
  
  
  11.         } 
    12.   
  
  
  12.     } 
    13.   
  
  
  13.     private volatile Pair pair; 
    14.
  • 如果我們不關(guān)心變量在中間過(guò)程是否被修改過(guò)，而只是關(guān)心當(dāng)前變量是否還是原先的變量，則可以使用AtomicMarkableReference
  • AtomicStampedReference的使用示例
 
 
 
    
  
  
  
  1. public class Main { 
    2.   
  
  
  2.     public static void main(String[] args) throws Exception { 
    3.   
  
  
  3.         Test old = new Test("hello"), newTest = new Test("world"); 
    4.   
  
  
  4.         AtomicStampedReference reference = new AtomicStampedReference<>(old, 1); 
    5.   
  
  
  5.         reference.compareAndSet(old, newTest,1,2); 
    6.   
  
  
  6.         System.out.println("對(duì)象："+reference.getReference().name+";版本號(hào)："+reference.getStamp()); 
    7.   
  
  
  7.     } 
    8.   
  
  
  8. } 
    9.   
  
  
  9. class Test{ 
    10.   
  
  
  10.     Test(String name){ this.name = name; } 
    11.   
  
  
  11.     public String name; 
    12.   
  
  
  12. } 
    13.   
  
  
  13. ---------------輸出結(jié)果------------------ 
    14.   
  
  
  14. 對(duì)象：world;版本號(hào)：2 
    15.

數(shù)組原子類

 
 
 
    
  
  
  
  1. AtomicIntegerArray //整型數(shù)組 
    2.   
  
  
  2.  
    3.   
  
  
  3. AtomicLongArray //長(zhǎng)整型數(shù)組 
    4.   
  
  
  4.  
    5.   
  
  
  5. AtomicReferenceArray //引用類型數(shù)組 
    6.
  • 數(shù)組原子類內(nèi)部會(huì)初始一個(gè)final的數(shù)組，它把整個(gè)數(shù)組當(dāng)做一個(gè)對(duì)象，然后根據(jù)下標(biāo)index計(jì)算法元素偏移量，再調(diào)用UNSAFE.compareAndSetReference進(jìn)行原子操作。數(shù)組并沒(méi)被volatile修飾，為了保證元素類型在不同線程的可見(jiàn)，獲取元素使用到了UNSAFEpublic native Object getReferenceVolatile(Object o, long offset)方法來(lái)獲取實(shí)時(shí)的元素值
  • 使用示例
 
 
 
    
  
  
  
  1. //元素默認(rèn)初始化為0 
    2.   
  
  
  2. AtomicIntegerArray array = new AtomicIntegerArray(2); 
    3.   
  
  
  3. // 下標(biāo)為０的元素，期待值是0，更新值是１ 
    4.   
  
  
  4. array.compareAndSet(0,0,1); 
    5.   
  
  
  5. System.out.println(array.get(0)); 
    6.   
  
  
  6. ---------------輸出結(jié)果------------------ 
    7.   
  
  
  7. 1 
    8.

屬性原子類

 
 
 
    
  
  
  
  1. AtomicIntegerFieldUpdater  
    2.   
  
  
  2. AtomicLongFieldUpdater 
    3.   
  
  
  3. AtomicReferenceFieldUpdater 
    4.
  • 如果操作對(duì)象是某一類型的屬性，可以使用AtomicIntegerFieldUpdater原子更新，不過(guò)類的屬性需要定義成volatile修飾的變量，保證該屬性在各個(gè)線程的可見(jiàn)性，否則會(huì)報(bào)錯(cuò)
  • 使用示例
 
 
 
    
  
  
  
  1. public class Main { 
    2.   
  
  
  2.     public static void main(String[] args) { 
    3.   
  
  
  3.         AtomicReferenceFieldUpdater fieldUpdater = AtomicReferenceFieldUpdater.newUpdater(Test.class,String.class,"name"); 
    4.   
  
  
  4.         Test test = new Test("hello world"); 
    5.   
  
  
  5.         fieldUpdater.compareAndSet(test,"hello world","siting"); 
    6.   
  
  
  6.         System.out.println(fieldUpdater.get(test)); 
    7.   
  
  
  7.         System.out.println(test.name); 
    8.   
  
  
  8.     } 
    9.   
  
  
  9. } 
    10.   
  
  
  10. class Test{ 
    11.   
  
  
  11.     Test(String name){ this.name = name; } 
    12.   
  
  
  12.     public volatile String name; 
    13.   
  
  
  13. } 
    14.   
  
  
  14. ---------------輸出結(jié)果------------------ 
    15.   
  
  
  15. siting 
    16.   
  
  
  16. siting 
    17.

累加器

 
 
 
    
  
  
  
  1. Striped64 
    2.   
  
  
  2. LongAccumulator 
    3.   
  
  
  3. LongAdder 
    4.   
  
  
  4. //accumulatorFunction：運(yùn)算規(guī)則，identity：初始值 
    5.   
  
  
  5. public LongAccumulator(LongBinaryOperator accumulatorFunction,long identity) 
    6.
  • LongAccumulator和LongAdder都繼承于Striped64，Striped64的主要思想是和ConcurrentHashMap有點(diǎn)類似，分段計(jì)算，單個(gè)變量計(jì)算并發(fā)性能慢時(shí)，我們可以把數(shù)學(xué)運(yùn)算分散在多個(gè)變量，而需要計(jì)算總值時(shí)，再一一累加起來(lái)
  • LongAdder相當(dāng)于LongAccumulator一個(gè)特例實(shí)現(xiàn)
  • LongAccumulator的示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     LongAccumulator accumulator = new LongAccumulator(Long::sum, 0); 
    3.   
  
  
  3.     for(int i=0;i<100000;i++){ 
    4.   
  
  
  4.         CompletableFuture.runAsync(() -> accumulator.accumulate(1)); 
    5.   
  
  
  5.     } 
    6.   
  
  
  6.     Thread.sleep(1000); //等待全部CompletableFuture線程執(zhí)行完成，再獲取 
    7.   
  
  
  7.     System.out.println(accumulator.get()); 
    8.   
  
  
  8. } 
    9.   
  
  
  9. ---------------輸出結(jié)果------------------ 
    10.   
  
  
  10. 100000 
    11.

同步組件的實(shí)現(xiàn)原理

java的多數(shù)同步組件會(huì)在內(nèi)部維護(hù)一個(gè)狀態(tài)值，和原子組件一樣，修改狀態(tài)值時(shí)一般也是通過(guò)cas來(lái)實(shí)現(xiàn)。而狀態(tài)修改的維護(hù)工作被Doug Lea抽象出AbstractQueuedSynchronizer(AQS)來(lái)實(shí)現(xiàn)

AQS的原理可以看下之前寫的一篇文章:詳解鎖原理，synchronized、volatile+cas底層實(shí)現(xiàn)[2]

同步組件

ReentrantLock、ReentrantReadWriteLock

  • ReentrantLock、ReentrantReadWriteLock都是基于AQS(AbstractQueuedSynchronizer)實(shí)現(xiàn)的。因?yàn)樗鼈冇泄芥i和非公平鎖的區(qū)分，因此沒(méi)直接繼承AQS，而是使用內(nèi)部類去繼承，公平鎖和非公平鎖各自實(shí)現(xiàn)AQS，ReentrantLock、ReentrantReadWriteLock再借助內(nèi)部類來(lái)實(shí)現(xiàn)同步
  • ReentrantLock的使用示例
 
 
 
    
  
  
  
  1. ReentrantLock lock = new ReentrantLock(); 
    2.   
  
  
  2. if(lock.tryLock()){ 
    3.   
  
  
  3.     //業(yè)務(wù)邏輯 
    4.   
  
  
  4.     lock.unlock(); 
    5.   
  
  
  5. } 
    6.
  • ReentrantReadWriteLock的使用示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); 
    3.   
  
  
  3.     if(lock.readLock().tryLock()){ //讀鎖 
    4.   
  
  
  4.         //業(yè)務(wù)邏輯 
    5.   
  
  
  5.         lock.readLock().unlock(); 
    6.   
  
  
  6.     } 
    7.   
  
  
  7.     if(lock.writeLock().tryLock()){ //寫鎖 
    8.   
  
  
  8.         //業(yè)務(wù)邏輯 
    9.   
  
  
  9.         lock.writeLock().unlock(); 
    10.   
  
  
  10.     } 
    11.   
  
  
  11. } 
    12.

Semaphore實(shí)現(xiàn)原理和使用場(chǎng)景

  • Semaphore和ReentrantLock一樣，也有公平和非公平競(jìng)爭(zhēng)鎖的策略，一樣也是通過(guò)內(nèi)部類繼承AQS來(lái)實(shí)現(xiàn)同步
  • 通俗解釋：假設(shè)有一口井，最多有三個(gè)人的位置打水。每有一個(gè)人打水，則需要占用一個(gè)位置。當(dāng)三個(gè)位置全部占滿時(shí)，第四個(gè)人需要打水，則要等待前三個(gè)人中一個(gè)離開(kāi)打水位，才能繼續(xù)獲取打水的位置
  • 使用示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     Semaphore semaphore = new Semaphore(2); 
    3.   
  
  
  3.     for (int i = 0; i < 3; i++) 
    4.   
  
  
  4.         CompletableFuture.runAsync(() -> { 
    5.   
  
  
  5.             try { 
    6.   
  
  
  6.                 System.out.println(Thread.currentThread().toString() + " start "); 
    7.   
  
  
  7.                 if(semaphore.tryAcquire(1)){ 
    8.   
  
  
  8.                     Thread.sleep(1000); 
    9.   
  
  
  9.                     semaphore.release(1); 
    10.   
  
  
  10.                     System.out.println(Thread.currentThread().toString() + " 無(wú)阻塞結(jié)束 "); 
    11.   
  
  
  11.                 }else { 
    12.   
  
  
  12.                     System.out.println(Thread.currentThread().toString() + " 被阻塞結(jié)束 "); 
    13.   
  
  
  13.                 } 
    14.   
  
  
  14.             } catch (Exception e) { 
    15.   
  
  
  15.                 throw new RuntimeException(e); 
    16.   
  
  
  16.             } 
    17.   
  
  
  17.         }); 
    18.   
  
  
  18.     //保證CompletableFuture 線程被執(zhí)行，主線程再結(jié)束 
    19.   
  
  
  19.     Thread.sleep(2000); 
    20.   
  
  
  20. } 
    21.   
  
  
  21. ---------------輸出結(jié)果------------------ 
    22.   
  
  
  22. Thread[ForkJoinPool.commonPool-worker-19,5,main] start  
    23.   
  
  
  23. Thread[ForkJoinPool.commonPool-worker-5,5,main] start  
    24.   
  
  
  24. Thread[ForkJoinPool.commonPool-worker-23,5,main] start  
    25.   
  
  
  25. Thread[ForkJoinPool.commonPool-worker-23,5,main] 被阻塞結(jié)束  
    26.   
  
  
  26. Thread[ForkJoinPool.commonPool-worker-5,5,main] 無(wú)阻塞結(jié)束  
    27.   
  
  
  27. Thread[ForkJoinPool.commonPool-worker-19,5,main] 無(wú)阻塞結(jié)束  
    28.

可以看出三個(gè)線程，因?yàn)樾盘?hào)量設(shè)定為2，第三個(gè)線程是無(wú)法獲取信息成功的，會(huì)打印阻塞結(jié)束

CountDownLatch實(shí)現(xiàn)原理和使用場(chǎng)景

  • CountDownLatch也是靠AQS實(shí)現(xiàn)的同步操作
  • 通俗解釋：玩游戲時(shí)，假如主線任務(wù)需要靠完成五個(gè)小任務(wù)，主線任務(wù)才能繼續(xù)進(jìn)行時(shí)。此時(shí)可以用CountDownLatch，主線任務(wù)阻塞等待，每完成一小任務(wù)，就done一次計(jì)數(shù)，直到五個(gè)小任務(wù)全部被執(zhí)行才能觸發(fā)主線
  • 使用示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     CountDownLatch count = new CountDownLatch(2); 
    3.   
  
  
  3.     for (int i = 0; i < 2; i++) 
    4.   
  
  
  4.         CompletableFuture.runAsync(() -> { 
    5.   
  
  
  5.             try { 
    6.   
  
  
  6.                 Thread.sleep(1000); 
    7.   
  
  
  7.                 System.out.println(" CompletableFuture over "); 
    8.   
  
  
  8.                 count.countDown(); 
    9.   
  
  
  9.             } catch (Exception e) { 
    10.   
  
  
  10.                 throw new RuntimeException(e); 
    11.   
  
  
  11.             } 
    12.   
  
  
  12.         }); 
    13.   
  
  
  13.     //等待CompletableFuture線程的完成 
    14.   
  
  
  14.     count.await(); 
    15.   
  
  
  15.     System.out.println(" main over "); 
    16.   
  
  
  16. } 
    17.   
  
  
  17. ---------------輸出結(jié)果------------------ 
    18.   
  
  
  18.  CompletableFuture over  
    19.   
  
  
  19.  CompletableFuture over  
    20.   
  
  
  20.  main over  
    21.

CyclicBarrier實(shí)現(xiàn)原理和使用場(chǎng)景

  • CyclicBarrier則是靠ReentrantLock lock和Condition trip屬性來(lái)實(shí)現(xiàn)同步
  • 通俗解釋：CyclicBarrier需要阻塞全部線程到await狀態(tài)，然后全部線程再全部被喚醒執(zhí)行。想象有一個(gè)欄桿攔住五只羊，需要當(dāng)五只羊一起站在欄桿時(shí)，欄桿才會(huì)被拉起，此時(shí)所有的羊都可以飛跑出羊圈
  • 使用示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     CyclicBarrier barrier = new CyclicBarrier(2); 
    3.   
  
  
  3.     CompletableFuture.runAsync(()->{ 
    4.   
  
  
  4.         try { 
    5.   
  
  
  5.             System.out.println("CompletableFuture run start-"+ Clock.systemUTC().millis()); 
    6.   
  
  
  6.             barrier.await(); //需要等待main線程也執(zhí)行到await狀態(tài)才能繼續(xù)執(zhí)行 
    7.   
  
  
  7.             System.out.println("CompletableFuture run over-"+ Clock.systemUTC().millis()); 
    8.   
  
  
  8.         }catch (Exception e){ 
    9.   
  
  
  9.             throw new RuntimeException(e); 
    10.   
  
  
  10.         } 
    11.   
  
  
  11.     }); 
    12.   
  
  
  12.     Thread.sleep(1000); 
    13.   
  
  
  13.     //和CompletableFuture線程相互等待 
    14.   
  
  
  14.     barrier.await(); 
    15.   
  
  
  15.     System.out.println("main run over!"); 
    16.   
  
  
  16. } 
    17.   
  
  
  17. ---------------輸出結(jié)果------------------ 
    18.   
  
  
  18. CompletableFuture run start-1609822588881 
    19.   
  
  
  19. main run over! 
    20.   
  
  
  20. CompletableFuture run over-1609822589880 
    21.

StampedLock

  • StampedLock不是借助AQS，而是自己內(nèi)部維護(hù)多個(gè)狀態(tài)值，并配合cas實(shí)現(xiàn)的
  • StampedLock具有三種模式：寫模式、讀模式、樂(lè)觀讀模式
  • StampedLock的讀寫鎖可以相互轉(zhuǎn)換
 
 
 
    
  
  
  
  1. //獲取讀鎖，自旋獲取，返回一個(gè)戳值 
    2.   
  
  
  2. public long readLock() 
    3.   
  
  
  3. //嘗試加讀鎖，不成功返回0 
    4.   
  
  
  4. public long tryReadLock() 
    5.   
  
  
  5. //解鎖 
    6.   
  
  
  6. public void unlockRead(long stamp)  
    7.   
  
  
  7. //獲取寫鎖，自旋獲取，返回一個(gè)戳值 
    8.   
  
  
  8. public long writeLock() 
    9.   
  
  
  9. //嘗試加寫鎖，不成功返回0 
    10.   
  
  
  10. public long tryWriteLock() 
    11.   
  
  
  11. //解鎖 
    12.   
  
  
  12. public void unlockWrite(long stamp) 
    13.   
  
  
  13. //嘗試樂(lè)觀讀讀取一個(gè)時(shí)間戳，并配合validate方法校驗(yàn)時(shí)間戳的有效性 
    14.   
  
  
  14. public long tryOptimisticRead() 
    15.   
  
  
  15. //驗(yàn)證stamp是否有效 
    16.   
  
  
  16. public boolean validate(long stamp) 
    17.
  • 使用示例
 
 
 
    
  
  
  
  1. public static void main(String[] args) throws Exception { 
    2.   
  
  
  2.     StampedLock stampedLock = new StampedLock(); 
    3.   
  
  
  3.     long stamp = stampedLock.tryOptimisticRead(); 
    4.   
  
  
  4.     //判斷版本號(hào)是否生效 
    5.   
  
  
  5.     if (!stampedLock.validate(stamp)) { 
    6.   
  
  
  6.         //獲取讀鎖，會(huì)空轉(zhuǎn) 
    7.   
  
  
  7.         stamp = stampedLock.readLock(); 
    8.   
  
  
  8.         long writeStamp = stampedLock.tryConvertToWriteLock(stamp); 
    9.   
  
  
  9.         if (writeStamp != 0) { //成功轉(zhuǎn)為寫鎖 
    10.   
  
  
  10.             //fixme 業(yè)務(wù)操作 
    11.   
  
  
  11.             stampedLock.unlockWrite(writeStamp); 
    12.   
  
  
  12.         } else { 
    13.   
  
  
  13.             stampedLock.unlockRead(stamp); 
    14.   
  
  
  14.             //嘗試獲取寫讀 
    15.   
  
  
  15.             stamp = stampedLock.tryWriteLock(); 
    16.   
  
  
  16.             if (stamp != 0) { 
    17.   
  
  
  17.                 //fixme 業(yè)務(wù)操作 
    18.   
  
  
  18.                 stampedLock.unlockWrite(writeStamp); 
    19.   
  
  
  19.             } 
    20.   
  
  
  20.         } 
    21.   
  
  
  21.     } 
    22.   
  
  
  22. }     
    23.

參考文章

  • 并發(fā)之Striped64(l累加器)[3]

參考資料

[1]詳解鎖原理，synchronized、volatile+cas底層實(shí)現(xiàn): https://juejin.cn/post/6854573210768900110

[2]詳解鎖原理，synchronized、volatile+cas底層實(shí)現(xiàn): https://juejin.cn/post/6854573210768900110

[3]并發(fā)之Striped64(l累加器): https://www.cnblogs.com/gosaint/p/9129867.html


標(biāo)題名稱：基礎(chǔ)篇：Java原子組件和同步組件
分享網(wǎng)址：http://uogjgqi.cn/article/dhioceg.html
掃二維碼與項(xiàng)目經(jīng)理溝通

我們?cè)谖⑿派?4小時(shí)期待你的聲音

解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流