一心多用多執行緒阻塞佇列（6） Semaphore

六、有序的排隊進場-semaphore

在現實中我們會經常遇到排隊進場的一種情況，一家餐廳能容納的最多人數是固定的，假設是4人，那麼如果來了20個人的話最多也就進去四個人吃，乙個吃完了走另外乙個人進去。在多執行緒中也會遇到這種情況，對資源來說或許每次只能支援4個執行緒進行作業，那麼我們就需要用到semaphore（訊號量，該訊號量與計算機系統裡面的訊號量作用效果不同）來對這個排隊進場流程進行控制，在需要限制的執行緒中我們通過semaphore的acquire方法來獲取許可，然後決定能否執行，通過release方法對許可進行釋放，在初始化semaphore物件的時候我們需要給定乙個int引數表示當前支援的許可數，即上述現實例子的餐廳能容納的最多人數，然後把這個機制通過semaphore去幫我們處理，當然在semaphore中也有提供了相應的api讓我們知道當前等待的執行緒數，當前可獲取的許可數等，下面通過**來熟悉這個排隊進場的過程。

public
class semaphoretest  catch (interruptedexception e1) 
system.out.println("顧客進場");
system.out.println("顧客開始吃飯");
try  catch (interruptedexception e) 
valve.release();
}});
consumer.start();
}while(true) catch (interruptedexception e) }}
}

結果：

顧客進場顧客開始吃飯顧客進場顧客開始吃飯顧客進場顧客進場顧客開始吃飯顧客開始吃飯 ---------------------- 當前還可通行數：0 當前作用佇列長度：6 當前是否有等待執行緒：true ---------------------- 顧客進場顧客開始吃飯顧客進場顧客開始吃飯顧客進場顧客開始吃飯顧客進場顧客開始吃飯 ---------------------- 當前還可通行數：0 當前作用佇列長度：2 當前是否有等待執行緒：true ---------------------- 顧客進場顧客開始吃飯顧客進場顧客開始吃飯 ---------------------- 當前還可通行數：2 當前作用佇列長度：0 當前是否有等待執行緒：false ---------------------- ---------------------- 當前還可通行數：4 當前作用佇列長度：0 當前是否有等待執行緒：false

----------------------

例子是一次性給出了十條執行緒，但是每次執行的執行緒只允許4條共同作業。通過上述**可以看出，如果使用訊號量對執行緒執行的**體進行控制的話，可以有效的決定當前最多的執行緒執行數，控制一定的併發量

一心多用多執行緒阻塞佇列（6） Semaphore

一心賺錢的人，親子關係差

萬眾一心讚國足出局

三心二意沒結果，一心一意又如何

一心多用多執行緒 阻塞佇列（6） Semaphore

一心賺錢的人，親子關係差

萬眾一心讚國足出局

三心二意沒結果，一心一意又如何

相關推薦

一心多用多執行緒阻塞佇列（6） Semaphore