Semaphore怎么在Java中中使用

這期內(nèi)容當中小編將會給大家?guī)碛嘘P(guān)Semaphore怎么在Java中中使用，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

10年積累的網(wǎng)站設(shè)計、成都網(wǎng)站設(shè)計經(jīng)驗，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認識你，你也不認識我。但先網(wǎng)站制作后付款的網(wǎng)站建設(shè)流程，更有東昌府免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

Semaphore的作用：

在java中，使用了synchronized關(guān)鍵字和Lock鎖實現(xiàn)了資源的并發(fā)訪問控制，在同一時間只允許唯一了線程進入臨界區(qū)訪問資源(讀鎖除外)，這樣子控制的主要目的是為了解決多個線程并發(fā)同一資源造成的數(shù)據(jù)不一致的問題。在另外一種場景下，一個資源有多個副本可供同時使用，比如打印機房有多個打印機、廁所有多個坑可供同時使用，這種情況下，Java提供了另外的并發(fā)訪問控制--資源的多副本的并發(fā)訪問控制，今天學(xué)習(xí)的信號量Semaphore即是其中的一種。

Semaphore實現(xiàn)原理初探：

Semaphore是用來保護一個或者多個共享資源的訪問，Semaphore內(nèi)部維護了一個計數(shù)器，其值為可以訪問的共享資源的個數(shù)。一個線程要訪問共享資源，先獲得信號量，如果信號量的計數(shù)器值大于1，意味著有共享資源可以訪問，則使其計數(shù)器值減去1，再訪問共享資源。

如果計數(shù)器值為0,線程進入休眠。當某個線程使用完共享資源后，釋放信號量，并將信號量內(nèi)部的計數(shù)器加1，之前進入休眠的線程將被喚醒并再次試圖獲得信號量。

就好比一個廁所管理員，站在門口，只有廁所有空位，就開門允許與空側(cè)數(shù)量等量的人進入廁所。多個人進入廁所后，相當于N個人來分配使用N個空位。為避免多個人來同時競爭同一個側(cè)衛(wèi)，在內(nèi)部仍然使用鎖來控制資源的同步訪問。

Semaphore的使用：

Semaphore使用時需要先構(gòu)建一個參數(shù)來指定共享資源的數(shù)量，Semaphore構(gòu)造完成后即是獲取Semaphore、共享資源使用完畢后釋放Semaphore。

Semaphore semaphore = new Semaphore(10,true);
semaphore.acquire();
//do something here
semaphore.release();

下面的代碼就是模擬控制商場廁所的并發(fā)使用：

public class ResourceManage { 
  private final Semaphore semaphore ; 
  private boolean resourceArray[]; 
  private final ReentrantLock lock; 
  public ResourceManage() { 
    this.resourceArray = new boolean[10];//存放廁所狀態(tài) 
    this.semaphore = new Semaphore(10,true);//控制10個共享資源的使用，使用先進先出的公平模式進行共享;公平模式的信號量，先來的先獲得信號量 
    this.lock = new ReentrantLock(true);//公平模式的鎖，先來的先選 
    for(int i=0 ;i<10; i++){ 
      resourceArray[i] = true;//初始化為資源可用的情況 
    } 
  } 
  public void useResource(int userId){ 
 semaphore.acquire(); 
    try{ 
      //semaphore.acquire(); 
      int id = getResourceId();//占到一個坑 
      System.out.print("userId:"+userId+"正在使用資源，資源id:"+id+"\n"); 
      Thread.sleep(100);//do something，相當于于使用資源 
      resourceArray[id] = true;//退出這個坑 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    }finally { 
      semaphore.release();//釋放信號量，計數(shù)器加1 
    } 
  } 
  private int getResourceId(){ 
    int id = -1; 
 lock.lock();
    try { 
      //lock.lock();//雖然使用了鎖控制同步，但由于只是簡單的一個數(shù)組遍歷，效率還是很高的，所以基本不影響性能。 
      for(int i=0; i<10; i++){ 
        if(resourceArray[i]){ 
          resourceArray[i] = false; 
          id = i; 
          break; 
        } 
      } 
    }catch (Exception e){ 
      e.printStackTrace(); 
    }finally { 
      lock.unlock(); 
    } 
    return id; 
  } 
} 
public class ResourceUser implements Runnable{ 
  private ResourceManage resourceManage; 
  private int userId; 
  public ResourceUser(ResourceManage resourceManage, int userId) { 
    this.resourceManage = resourceManage; 
    this.userId = userId; 
  } 
  public void run(){ 
    System.out.print("userId:"+userId+"準備使用資源...\n"); 
    resourceManage.useResource(userId); 
    System.out.print("userId:"+userId+"使用資源完畢...\n"); 
  } 
 
  public static void main(String[] args){ 
    ResourceManage resourceManage = new ResourceManage(); 
    Thread[] threads = new Thread[100]; 
    for (int i = 0; i < 100; i++) { 
      Thread thread = new Thread(new ResourceUser(resourceManage,i));//創(chuàng)建多個資源使用者 
      threads[i] = thread; 
    } 
    for(int i = 0; i < 100; i++){ 
      Thread thread = threads[i]; 
      try { 
        thread.start();//啟動線程 
      }catch (Exception e){ 
        e.printStackTrace(); 
      } 
    } 
  } 
}

最后，Semaphore除了控制資源的多個副本的并發(fā)訪問控制，也可以使用二進制信號量來實現(xiàn)類似synchronized關(guān)鍵字和Lock鎖的并發(fā)訪問控制功能。

上述就是小編為大家分享的Semaphore怎么在Java中中使用了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

分享文章：Semaphore怎么在Java中中使用
URL鏈接：http://muchs.cn/article12/picpgc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)網(wǎng)站制作、網(wǎng)站改版、網(wǎng)站排名、定制網(wǎng)站、微信公眾號、軟件開發(fā)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容