悲觀讀/寫鎖示例

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

樂觀讀失效，升級為悲觀讀

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

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

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

StampedLock 讀模板：

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

StampedLock 寫模板：

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。