91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Java中的鎖實現原理及優缺點

發布時間:2021-08-26 15:11:52 來源:億速云 閱讀:137 作者:chen 欄目:大數據

本篇內容介紹了“Java中的鎖實現原理及優缺點”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!

locks包結構層次

Lock 接口

方法簽名描述
void lock();獲取鎖(不死不休)
boolean tryLock();獲取鎖(淺嘗輒止)
boolean tryLock(long time, TimeUnit unit) throws InterruptedException;獲取鎖(過時不候)
void lockInterruptibly() throws InterruptedException;獲取鎖(任人擺布)
void unlock();釋放鎖
Condition newCondition();

代碼示例:

public class GetLockDemo {

  // 公平鎖
  // static Lock lock =new ReentrantLock(true);

  // 非公平鎖
  static Lock lock = new ReentrantLock();

  public static void main(String[] args) throws InterruptedException {
    // 主線程 拿到鎖
    lock.lock();

    Thread thread =
        new Thread(
            () -> {
              // 子線程 獲取鎖(不死不休)
              System.out.println("begain to get lock...");
              lock.lock();
              System.out.println("succeed to get lock...");

              //              // 子線程 獲取鎖(淺嘗輒止)
              //              boolean result = lock.tryLock();
              //              System.out.println("是否獲得到鎖:" + result);
              //
              //              // 子線程 獲取鎖(過時不候)
              //              try {
              //                boolean result1 = lock.tryLock(5, TimeUnit.SECONDS);
              //                System.out.println("是否獲得到鎖:" + result1);
              //              } catch (InterruptedException e) {
              //                e.printStackTrace();
              //              }
              //
              //              // 子線程 獲取鎖(任人擺布)
              //              try {
              //                System.out.println("start to get lock Interruptibly");
              //                lock.lockInterruptibly();
              //              } catch (InterruptedException e) {
              //                e.printStackTrace();
              //                System.out.println("dad asked me to stop...");
              //              }

            });

    thread.start();
    Thread.sleep(10000L);
    lock.unlock();
  }
}

結論:

  • lock() 最常用

  • lockInterruptibly() 方法一般更昂貴,有的實現類可能沒有實現 lockInterruptible() 方法。只有真的需要用中斷時,才使用,使用前應看清實現類對該方法的描述。

Condition

Object中的wait(), notify(), notifyAll()方法是和synchronized配合使用的可以喚醒一個或者多個線程。Condition是需要與Lock配合使用的,提供多個等待集合和更精確的控制(底層是park/unpark機制); | 協作方式 | 死鎖方式1 (鎖) | 死鎖方式2(先喚醒,再掛起)| 備注 | | ---- | ---- | ---- |---- | | suspend/resume | 死鎖 | 死鎖 | 棄用 | | wait/notify | 不死鎖 | 死鎖 | 只用于synchronized關鍵字 | | park/unpark | 死鎖 | 不死鎖 | | | condition | 不死鎖 | 死鎖 | |

condition代碼示例:

public class ConditionDemo {

  static Lock lock = new ReentrantLock();

  static Condition condition = lock.newCondition();

  public static void main(String[] args) throws InterruptedException {
    Thread thread =
        new Thread(
            () -> {
              lock.lock();
              System.out.println("condition.await()");
              try {
                condition.await();
                System.out.println("here i am...");
              } catch (InterruptedException e) {
                e.printStackTrace();
              } finally {
                lock.unlock();
              }
            });
    thread.start();

    Thread.sleep(2000L);
    lock.lock();

    condition.signalAll();

    lock.unlock();
  }
}

ReetrantLock

ReentrantLock是可重入鎖,同一線程可以多次獲取到鎖 Java中的鎖實現原理及優缺點

ReentrantLock實現原理分析

  1. ReentrantLock需要一個owner用來標記那個線程獲取到了鎖,一個count用來記錄加鎖的次數和一個waiters等待隊列用來存放沒有搶到鎖的線程列表

  2. 當有線程進來時,會先判斷count的值,如果count為0說明鎖沒有被占用

  3. 然后通過CAS操作進行搶鎖

  4. 如果搶到鎖則count的值會加1,同時將owner設置為當前線程的引用

  5. 如果count不為0同時owner指向當前線程的引用,則將count的值加1

  6. 如果count不為0同時owner指向的不是當前線程的引用,則將線程放入等待隊列waiters中

  7. 如果CAS搶鎖失敗,則將線程放入等待隊列waiters中

  8. 當線程使用完鎖后,會釋放其持有的鎖,釋放鎖時會將count的值減1,如果count值為0則將owner設為null

  9. 如果count值不為0則會喚醒等待隊列頭部的線程進行搶鎖

手動實現ReentrantLock代碼示例:

public class MyReentrantLock implements Lock {

  // 標記重入次數的count值
  private AtomicInteger count = new AtomicInteger(0);

  // 鎖的擁有者
  private AtomicReference<Thread> owner = new AtomicReference<>();

  // 等待隊列
  private LinkedBlockingDeque<Thread> waiters = new LinkedBlockingDeque<>();

  @Override
  public boolean tryLock() {
    // 判斷count是否為0,若count!=0,說明鎖被占用
    int ct = count.get();
    if (ct != 0) {
      // 判斷鎖是否被當前線程占用,若被當前線程占用,做重入操作,count+=1
      if (owner.get() == Thread.currentThread()) {
        count.set(ct + 1);
        return true;
      } else {
        // 若不是當前線程占用,互斥,搶鎖失敗,return false
        return false;
      }
    } else {
      // 若count=0, 說明鎖未被占用,通過CAS(0,1) 來搶鎖
      if (count.compareAndSet(ct, ct + 1)) {
        // 若搶鎖成功,設置owner為當前線程的引用
        owner.set(Thread.currentThread());
        return true;
      } else {
        return false;
      }
    }
  }

  @Override
  public void lock() {
    // 嘗試搶鎖
    if (!tryLock()) {
      // 如果失敗,進入等待隊列
      waiters.offer(Thread.currentThread());

      // 自旋
      for (; ; ) {
        // 判斷是否是隊列頭部,如果是
        Thread head = waiters.peek();
        if (head == Thread.currentThread()) {
          // 再次嘗試搶鎖
          if (!tryLock()) {
            // 若搶鎖失敗,掛起線程,繼續等待
            LockSupport.park();
          } else {
            // 若成功,就出隊列
            waiters.poll();
            return;
          }
        } else {
          // 如果不是隊列頭部,就掛起線程
          LockSupport.park();
        }
      }
    }
  }

  public boolean tryUnlock() {
    // 判斷,是否是當前線程占有鎖,若不是,拋異常
    if (owner.get() != Thread.currentThread()) {
      throw new IllegalMonitorStateException();
    } else {
      // 如果是,就將count-1  若count變為0 ,則解鎖成功
      int ct = count.get();
      int nextc = ct - 1;
      count.set(nextc);
      // 判斷count值是否為0
      if (nextc == 0) {
        owner.compareAndSet(Thread.currentThread(), null);
        return true;
      } else {
        return false;
      }
    }
  }

  @Override
  public void unlock() {
    // 嘗試釋放鎖
    if (tryUnlock()) {
      // 獲取隊列頭部, 如果不為null則將其喚醒
      Thread thread = waiters.peek();
      if (thread != null) {
        LockSupport.unpark(thread);
      }
    }
  }

  @Override
  public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
    return false;
  }

  @Override
  public void lockInterruptibly() throws InterruptedException {}

  @Override
  public Condition newCondition() {
    return null;
  }
}

synchronized VS Lock

synchronized: 優點:

  • 使用簡單,語義清晰,哪里需要點哪里

  • 由JVM提供,提供了多種優化方案(鎖粗化,鎖消除,偏向鎖,輕量級鎖)

  • 鎖的釋放由虛擬機完成,不用人工干預,降低了死鎖的可能性

缺點:悲觀的排他鎖,無法實現鎖的高級功能如公平鎖,讀寫鎖等

Lock: 優點:可以實現synchronized無法實現的鎖的高級功能如公平鎖,讀寫鎖等,同時還可以實現更多的功能 

缺點:需手動釋放鎖unlock,使用不當容易造成死鎖

結論: 兩者都是可重入鎖,synchronized可以類比為傻瓜相機,提供了固定的功能,而Lock可以類比為單方,可以根據需要調節所需的功能

“Java中的鎖實現原理及優缺點”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

桦川县| 花垣县| 武隆县| 潮安县| 轮台县| 沐川县| 古交市| 叶城县| 建德市| 祁连县| 北安市| 枣阳市| 西安市| 呼和浩特市| 龙江县| 巧家县| 岐山县| 蒲江县| 枣阳市| 平顶山市| 洞口县| 江陵县| 珲春市| 康乐县| 西和县| 上林县| 承德县| 花垣县| 黄浦区| 前郭尔| 信宜市| 顺平县| 三穗县| 阳曲县| 金溪县| 扶风县| 忻州市| 鄂州市| 玉屏| 准格尔旗| 开封市|