進階訓練營七課

1.1.Java并發(fā)心庫的包心庫的包鎖原子線程工具集合鎖原子線程工具集合2.到2.到底什么是完整版獲取加微信要顯式的要顯式的鎖完鎖完整版獲取加微信口重要方法獲取鎖;類比synchronized口重要方法獲取鎖;類比synchronized獲取鎖許打斷ongtime,TimeUnitunit) 嘗試獲取鎖;成功則返回true超時則退出版獲取加微信;嘗試【無等待】獲取鎖;成功則返回解鎖；要求當前線程已獲得鎖 類比同步塊結(jié)示例:（類比:Objectmonitor）finalLocklock=newfinalConditionnotFull=finalConditionnotEmpty=例//publicstaticvoidtestLockCounter()intloopNum例//publicstaticvoidtestLockCounter()intloopNum=LockCountercounter=newLockCounter();IntStream.range(0,loopNum).parallel()um=平鎖ock=new-}–接口與實現(xiàn)publicclass{privateintsum=–接口與實現(xiàn)publicclass{privateintsum=//可重入-讀寫鎖-公平privateReadWriteLocklock=publicintincrAndGet(){trylock.writeLock().lock();//寫鎖;獨占鎖;return}{}publicint{trylock.readLock().lock();//讀鎖;//共享鎖;return}{}}ewFairSync():new{newnew管理一組鎖，一個讀鎖，一個寫鎖寫鎖的時候被多個線程同時持有，寫鎖是獨占的現(xiàn)必須確保寫操作對讀操作的內(nèi)存影響。每次只能有一個寫線程，但;獲取讀鎖享獲取寫鎖;獨占鎖(也排斥讀鎖-重要方法說明等待信號;類比等待-重要方法說明等待信號;類比等待信號ait(longtime,TimeUnitruptedException;完整版獲取信aitUntil(Date;給一個等待線程發(fā)送喚醒信號 類Object#notify類比Object#notifyAll()pport--鎖當pport--鎖當前線程完整版獲取加微信佳實踐佳實踐2.并2.并發(fā)原子完整版獲取加微信工具類icCounternteger工具類icCounterntegerntendGet()，intsum，sum++–Atomic工具類完整版獲取加微–Atomic工具類完整版獲取加微信原理tile保證讀寫操作都可見（注意不保證原子指作為樂觀鎖實通過自旋重試保證寫之爭CAS之爭CAS本質(zhì)上沒有使用鎖并發(fā)性能w關(guān)系：2、壓力一般的情況下，無鎖更快，大部分都一次寫入3、壓力非常大時，自旋導致重試過多，資源消耗很大der對AtomicLong的改進der對AtomicLong的改進1、AtomicInteger和AtomicLong里的value是所有2value3、每個線程寫自己Cell[i]++，最后對數(shù)組求和3.3.并發(fā)工具發(fā)工具類更復發(fā)工具類更復雜的應用場景，比我們需要控制實際并發(fā)訪問資源的并發(fā)數(shù)我們需要多個線程在某個時間同時開始運我們需要指定數(shù)量線程到達某個狀態(tài)再繼續(xù)處hore信號量hore信號量publicclass{privateintsum=privateSemaphorereadSemaphore=newSemaphore(100,true);privateSemaphorewriteSemaphore=newSemaphore(1);publicintincrAndGet()tryreturn++sum;}finally完整版獲取加微witySemaphore.release();}}publicint{tryreturnsum;}{}}}重要方說publicCountDownLatch(int構(gòu)造重要方說publicCountDownLatch(int構(gòu)造方法（總數(shù)voidawait()throws等待數(shù)量歸booleanawait(longtimeout,TimeUnit限時等i整no信等待數(shù)減long返回剩余數(shù)示例//publicstaticvoidmain(String[]示例//publicstaticvoidmain(String[]throws{intnum=100;CountDownLatchlatch=newList<CompletableFuture>list=newfor(inti=0;i<num;{CompletableFuture<Void>future=new}for(CompletableFuturefuture:{}}tchchTask(CountDownLatch(“我的任務)rrier(int構(gòu)造方法（需要等rrier(int構(gòu)造方法（需要等待的數(shù)量rrier(intparties,Runnable構(gòu)造方法（需要等待的數(shù)量 需要執(zhí)行的任務任務內(nèi)部使用;等待大家都到imeout,TimeUnit任務內(nèi)部使用;限時等待到重新一arrier示例publicstaticvoidmain(String[]args)throws{arrier示例publicstaticvoidmain(String[]args)throws{intnum2//如果數(shù)量過大會發(fā)生什么情況{CyclicBarrierbarrier=newsk(CyclicBarrierList<CompletableFuture>list=newArrayList<>(num);for(inti=0;i<num;i++){CompletableFuture<Void>futureCompletableFuture.runAsync(newCyclicBarrierTask(barrier));}for(CompletableFuturefuture:{t(n(“開吃})}ownLatch與ownLatch與CyclicBarrier比較完整版獲取加微信ownLatch與ownLatch與CyclicBarrier比較完整版獲取加微信完整完整版獲取加微信leanuseCommonPool.getCommonPoolParallelism()>是否使用內(nèi)leanuseCommonPool.getCommonPoolParallelism()>是否使用內(nèi)置線程utorasyncPool=useCommonPoolcommonPool():new線程ure<Void>runAsync(Runnable異步執(zhí)行【當心阻塞？ure<Void>runAsync(R