java并發(fā)編程專題（六）----淺析（JUC）Semaphore

更新時(shí)間：2020年07月01日 10:59:11 作者：rickiyang

這篇文章主要介紹了java JUC）Semaphore的相關(guān)資料，文中示例代碼非常詳細(xì)，供大家參考和學(xué)習(xí)，感興趣的朋友可以了解下

半路開始看的朋友可以回顧一下前幾篇

java并發(fā)編程專題（一）----線程基礎(chǔ)知識(shí)

java并發(fā)編程專題（二）----如何創(chuàng)建并運(yùn)行java線程

java并發(fā)編程專題（三）----詳解線程的同步

java并發(fā)編程專題（四）----淺談（JUC）Lock鎖

java并發(fā)編程專題（五）----詳解（JUC）ReentrantLock

Semaphore,從字面意義上我們知道他是信號(hào)量的意思。在java中，一個(gè)計(jì)數(shù)信號(hào)量維護(hù)了一個(gè)許可集。Semaphore 只對(duì)可用許可的號(hào)碼進(jìn)行計(jì)數(shù)，并采取相應(yīng)的行動(dòng)。拿到信號(hào)量的線程可以進(jìn)入代碼，否則就等待。通過acquire()和release()獲取和釋放訪問許可。

信號(hào)量Semaphore是一個(gè)控制訪問多個(gè)共享資源的計(jì)數(shù)器，它本質(zhì)上是一個(gè)“共享鎖”。

Java并發(fā)提供了兩種加鎖模式：共享鎖和獨(dú)占鎖。前面介紹的ReentrantLock就是獨(dú)占鎖。對(duì)于獨(dú)占鎖而言，它每次只能有一個(gè)線程持有，而共享鎖則不同，它允許多個(gè)線程并行持有鎖，并發(fā)訪問共享資源。

獨(dú)占鎖它所采用的是一種悲觀的加鎖策略，對(duì)于寫而言為了避免沖突獨(dú)占是必須的，但是對(duì)于讀就沒有必要了，因?yàn)樗粫?huì)影響數(shù)據(jù)的一致性。如果某個(gè)只讀線程獲取獨(dú)占鎖，則其他讀線程都只能等待了，這種情況下就限制了不必要的并發(fā)性，降低了吞吐量。而共享鎖則不同，它放寬了加鎖的條件，采用了樂觀鎖機(jī)制，它是允許多個(gè)讀線程同時(shí)訪問同一個(gè)共享資源的。

舉一個(gè)生活中的例子，有一條單行道路口有一紅綠燈在正常的綠燈時(shí)間內(nèi)如果騎車速度都很平均只能過去20輛車，這就意味著排在前面的20輛肯定能過去紅綠燈，后面的就只能等下一個(gè)綠燈了。但是如果這個(gè)時(shí)候有車不想過去這個(gè)路口它駛向了邊上別的路，那么后面的車就有機(jī)會(huì)。下面我們來看一個(gè)簡單的例子：

public class TestSemaphore {
 public static void main(String[] args) {
  final Semaphore semaphore = new Semaphore(5);
  ExecutorService executorService = Executors.newCachedThreadPool();
  for(int i = 0;i<10;i++){
   int j = 0;
   executorService.submit(new A("car"+(j++),semaphore),"Thread"+(j++));
   //new Thread(new A("car"+(j++),semaphore),"Thread"+(j++)).start();
   if(i == 5){
    try {
     Thread.sleep(1000);
     System.out.println("最后還有"+semaphore.availablePermits()+"個(gè)許可可用");
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
  }

  System.out.println("最后還有"+semaphore.availablePermits()+"個(gè)許可可用");
 }

 }
 class A implements Runnable{
  String carName;
  private Semaphore semaphore;

  public A(String carName, Semaphore semaphore){
   this.carName = carName;
   this.semaphore = semaphore;
  }

  public void getWay(){
   System.out.println("this car is get the way" + Thread.currentThread().getName());
  }

  public void run() {
   try {
    if(semaphore.availablePermits() > 0){
     semaphore.acquire();
     getWay();
     semaphore.release();
    }else{
     System.out.println("請等待========");
    }
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }

以上就是java并發(fā)編程專題（六）----淺析（JUC）Semaphore的詳細(xì)內(nèi)容，更多關(guān)于JAVA Semaphore的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: