Java高併發12-避免僞共享和鎖機制

1、複習

2、如何避免僞共享

• 在JDK8以前是使用填充字節的方式來避免僞共享的，咱們最終的目的其實就是但願單個變量可以獨佔一個緩存行。
• 咱們舉一個類的例子

package com.ruigege.OtherFoundationOfConcurrent2;

public class FiledLong {
 public volatile long value =0L;
 public long p1,p2,p3,p4,p5,p6;
}

• 能夠看這個類，若是cache行僞64個字節，那麼正好可以佔滿，七個long類型的變量，其中p1-p6都是用來佔位，還有一個對象的頭佔用八個字節，正好64個字節。
• 在JDK8中提供了一個註解，用於避免僞共享

@sun.misc.Contended
class FiledLong2{
 public volatile long value=0L;
}

• 用法：既能夠用修飾類也能夠用來修飾變量。

注意點：@Contended註解只能用於Java的核心類，好比rt包下的類，若是用戶的類須要使用這個註解的時候，須要添加JVM的參數:-XX:-RestrictContended,填充的默認寬度爲128，要自定義寬度能夠設置-XX:ContendedPaddingWidth參數

3、出現僞共享內存的條件

• 在多線程下訪問同一個緩存行的多個變量，纔會出現僞共享變量的問題，若是在單線程下訪問多個變量反而會加速訪問。

4、樂觀鎖和悲觀鎖

1.悲觀鎖

• 定義：悲觀鎖認爲外界對數據的修改持保守態度，認爲數據很容易被外界修改，在數據被處理以前必須先加鎖，這種鎖是排他鎖，一個線程獲取了鎖以後，其餘線程只能等待或者拋出異常。獲取鎖的線程，對記錄進行操做，而後提交事務釋放鎖。下面舉一個例子

 //使用悲觀鎖來獲取
 EntryObject entry = query("select * from table1 where id =#{id} for update",id);
 //修改記錄內容，根據計算修改entry記錄的屬性
 String name=generatorName(entry);
 entry.setName(name);
 
 //update操做
 int count = updateZ("update table1 set name=#{name},age=#{age} where id=#{id}",entry);
 return count;

• 對於上面的代碼，使用了事務切面的方法，只要進入這個方法種就開始執行事物一直到這個方法結束，多個線程調用這個方法的時候，只有一個線程可以獲取鎖，其餘線程就會阻塞掛起，直到原線程釋放鎖
• 樂觀鎖是相對悲觀鎖而存在的的方式，通常認爲若是隻是訪問數據那麼就是能夠不用加鎖，只有要更新數據的時候，纔會正式對數據衝突與否進行檢測，具體來講，根據update返回的行數讓用戶決定如何去作。將上面的例子改成樂觀鎖。

package com.ruigege.OtherFoundationOfConcurrent2;

public class UpdateEntry2 {

 public int updateEntry(long id) {
  //使用樂觀鎖獲取指定記錄
  EntryObject entry = query("select * from table1 where id=#{id}",id);
  
  //
  String name = generatorName(entry);
  entry.setName(name);
  
  //update操做
  int count = update("update table1 set name=#{name},age=#{age},version=${version}+1 where id=#{id} and version =#{version}",entry);
  return count;
 }
}

• 對比上面的代碼就能夠知道根據version來進行更新數據，更新成功的話，就會給version+1,其餘線程進行更新的時候，若是vesion不對的話，那麼就會中止更新。咱們也是使用不斷地循環來獲取鎖而解決更新的問題

package com.ruigege.OtherFoundationOfConcurrent2;

public class updateEntry3 {

 boolean result = false;
 int retryNum = 5;
 while(retryNum>0) {
  //使用樂觀鎖獲取記錄
  EntryObject entry = query("select * from table1 where id=#{id}",id);
  String name = generatorName(entry);
  entry.setName(name);
  
  //update操做
  int count = update("update table1 set name=#{name},age=#{age},version=${version}+1 where id=#{id} and version =#{version}",entry);
  //返回的行若是不是0的話說明更新成功了，那麼即刻跳出循環
  if(count == 1) {
   result = true;
   break;
  }
  retryNum--;
  
 }
 return result;
}

• 樂觀鎖並不會使用數據庫提供的鎖機制，通常在表中添加version字段或者使用業務狀態來實現，樂觀鎖直到提交時才鎖定，因此不會產生任何死鎖。

5、公平鎖和非公平鎖

• 公平鎖表示線程獲取鎖的順序是按照先到先得的原則，非公平鎖在運行的時候闖入，也就是不必定先到先得。
• ReentrantLock提供了公平和非公平鎖。

六 、源碼：

• 所在包：com.ruigege.OtherFoundationOfConcurrent2
• https://github.com/ruigege66/ConcurrentJava
• CSDN： https://blog.csdn.net/weixin_44630050
• 博客園： https://www.cnblogs.com/ruigege0000/
• 歡迎關注微信公衆號：傅里葉變換，我的帳號，僅用於技術交流