悲觀讀/寫(xiě)鎖示例

final StampedLock sl = new StampedLock();// 獲取 / 釋放悲觀讀鎖示意代碼 long stamp = sl.readLock(); try {// 省略業(yè)務(wù)相關(guān)代碼 } finally {sl.unlockRead(stamp); }// 獲取 / 釋放寫(xiě)鎖示意代碼 long stamp = sl.writeLock(); try {// 省略業(yè)務(wù)相關(guān)代碼 } finally {sl.unlockWrite(stamp); }

樂(lè)觀讀失效，升級(jí)為悲觀讀

public class Point {private int x, y;final StampedLock sl = new StampedLock();// 計(jì)算到原點(diǎn)的距離 int distanceFromOrigin() {// 樂(lè)觀讀long stamp = sl.tryOptimisticRead();// 讀入局部變量，// 讀的過(guò)程數(shù)據(jù)可能被修改int curX = x, curY = y;// 判斷執(zhí)行讀操作期間，// 是否存在寫(xiě)操作，如果存在，// 則 sl.validate 返回 falseif (!sl.validate(stamp)){// 升級(jí)為悲觀讀鎖stamp = sl.readLock();try {curX = x;curY = y;} finally {// 釋放悲觀讀鎖sl.unlockRead(stamp);}}return Math.sqrt(curX * curX + curY * curY);} }

有一點(diǎn)需要特別注意，那就是：如果線程阻塞在 StampedLock 的 readLock() 或者 writeLock() 上時(shí)，此時(shí)調(diào)用該阻塞線程的 interrupt() 方法，會(huì)導(dǎo)致 CPU 飆升。例如下面的代碼中，線程 T1 獲取寫(xiě)鎖之后將自己阻塞，線程 T2 嘗試獲取悲觀讀鎖，也會(huì)阻塞；如果此時(shí)調(diào)用線程 T2 的 interrupt() 方法來(lái)中斷線程 T2 的話，你會(huì)發(fā)現(xiàn)線程 T2 所在 CPU 會(huì)飆升到 100%。

final StampedLock lock= new StampedLock(); Thread T1 = new Thread(()->{// 獲取寫(xiě)鎖lock.writeLock();// 永遠(yuǎn)阻塞在此處，不釋放寫(xiě)鎖LockSupport.park(); }); T1.start(); // 保證 T1 獲取寫(xiě)鎖 Thread.sleep(100);Thread T2 = new Thread(()->// 阻塞在悲觀讀鎖lock.readLock() ); T2.start(); // 保證 T2 阻塞在讀鎖 Thread.sleep(100); // 中斷線程 T2 // 會(huì)導(dǎo)致線程 T2 所在 CPU 飆升 T2.interrupt(); T2.join();

StampedLock 讀模板：

final StampedLock sl = new StampedLock();// 樂(lè)觀讀 long stamp = sl.tryOptimisticRead(); // 讀入方法局部變量 ...... // 校驗(yàn) stamp if (!sl.validate(stamp)){// 升級(jí)為悲觀讀鎖stamp = sl.readLock();try {// 讀入方法局部變量.....} finally {// 釋放悲觀讀鎖sl.unlockRead(stamp);} } // 使用方法局部變量執(zhí)行業(yè)務(wù)操作 ......

StampedLock 寫(xiě)模板：

long stamp = sl.writeLock(); try {// 寫(xiě)共享變量...... } finally {sl.unlockWrite(stamp); }

總結(jié)

以上是生活随笔為你收集整理的Java并发编程实战~StampedLock的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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