溫馨提示×

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

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

如何解決Java多線程的臨界資源問(wèn)題

發(fā)布時(shí)間:2021-08-04 10:21:40 來(lái)源:億速云 閱讀:140 作者:小新 欄目:編程語(yǔ)言

小編給大家分享一下如何解決Java多線程的臨界資源問(wèn)題,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!

臨界資源問(wèn)題的原因:某一個(gè)線程在對(duì)臨界資源進(jìn)行訪問(wèn)時(shí),還沒(méi)來(lái)得及完全修改臨界資源的值,臨界資源就被其他線程拿去訪問(wèn),導(dǎo)致多個(gè)線程訪問(wèn)同一資源。直觀表現(xiàn)為打印結(jié)果順序混亂。

解決方法:加鎖

靜態(tài)方法中用類鎖,非靜態(tài)方法中用對(duì)象鎖。

1.同步代碼段:synchronized(){...}

2.同步方法:使用關(guān)鍵字synchronized修飾的方法

3.使用顯式同步鎖ReentrantLock

鎖池描述的即為鎖外等待的狀態(tài)

方法一:同步代碼段:synchronized(){...}

public class SourceConflict {
  public static void main(String[] args) {
    //實(shí)例化4個(gè)售票員,用4個(gè)線程模擬4個(gè)售票員
    
    Runnable r = () -> {
      while (TicketCenter.restCount > 0) {
        synchronized(" ") {
          if (TicketCenter.restCount <= 0) {
            return;
          }
          System.out.println(Thread.currentThread().getName() + "賣出一張票,剩余" + --TicketCenter.restCount + "張票");
        }
      }
    };
    
    //用4個(gè)線程模擬4個(gè)售票員
    Thread thread1 = new Thread(r, "thread-1");
    Thread thread2 = new Thread(r, "thread-2");
    Thread thread3 = new Thread(r, "thread-3");
    Thread thread4 = new Thread(r, "thread-4");
    
    //開(kāi)啟線程
    thread1.start();
    thread2.start();
    thread3.start();
    thread4.start();
    
  }  
}

//實(shí)現(xiàn)四名售票員共同售票,資源共享,非獨(dú)立
//Lambda表達(dá)式或匿名內(nèi)部類內(nèi)部捕獲的局部變量必須顯式的聲明為 final 或?qū)嶋H效果的的 final 類型,而捕獲實(shí)例或靜態(tài)變量是沒(méi)有限制的
class TicketCenter{
  public static int restCount = 100; 
}

方法二:同步方法,即使用關(guān)鍵字synchronized修飾的方法

public class SourceConflict2 {
  public static void main(String[] args) {
    //實(shí)例化4個(gè)售票員,用4個(gè)線程模擬4個(gè)售票員
    
    Runnable r = () -> {
      while (TicketCenter.restCount > 0) {
        sellTicket();
      }
    };
    
    //用4個(gè)線程模擬4個(gè)售票員
    Thread thread1 = new Thread(r, "thread-1");
    Thread thread2 = new Thread(r, "thread-2");
    Thread thread3 = new Thread(r, "thread-3");
    Thread thread4 = new Thread(r, "thread-4");
    
    //開(kāi)啟線程
    thread1.start();
    thread2.start();
    thread3.start();
    thread4.start();
    
  }
  
  private synchronized static void sellTicket() {  
    if (TicketCenter.restCount <= 0) {
      return;
    }
    System.out.println(Thread.currentThread().getName() + "賣出一張票,剩余" + --TicketCenter.restCount + "張票");
  }
}

class TicketCenter{
  public static int restCount = 100; 
}

方法三:使用顯式同步鎖ReentrantLock

import java.util.concurrent.locks.ReentrantLock;

public class SourceConflict3 {
  public static void main(String[] args) {
    //實(shí)例化4個(gè)售票員,用4個(gè)線程模擬4個(gè)售票員
    
    //顯式鎖
    ReentrantLock lock = new ReentrantLock();
    Runnable r = () -> {
      while (TicketCenter.restCount > 0) {
        lock.lock();
        if (TicketCenter.restCount <= 0) {
          return;
        }
        System.out.println(Thread.currentThread().getName() + "賣出一張票,剩余" + --TicketCenter.restCount + "張票");
        lock.unlock();
      }
    };
    
    //用4個(gè)線程模擬4個(gè)售票員
    Thread thread1 = new Thread(r, "thread-1");
    Thread thread2 = new Thread(r, "thread-2");
    Thread thread3 = new Thread(r, "thread-3");
    Thread thread4 = new Thread(r, "thread-4");
    
    //開(kāi)啟線程
    thread1.start();
    thread2.start();
    thread3.start();
    thread4.start();
    
  }  
}
class TicketCenter{
  public static int restCount = 100; 
}

看完了這篇文章,相信你對(duì)“如何解決Java多線程的臨界資源問(wèn)題”有了一定的了解,如果想了解更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI