java并發(fā)編程專題(六)----淺析(JUC)Semaphore
半路開始看的朋友可以回顧一下前幾篇
java并發(fā)編程專題(一)----線程基礎(chǔ)知識
java并發(fā)編程專題(二)----如何創(chuàng)建并運行java線程
java并發(fā)編程專題(三)----詳解線程的同步
java并發(fā)編程專題(四)----淺談(JUC)Lock鎖
java并發(fā)編程專題(五)----詳解(JUC)ReentrantLock
Semaphore,從字面意義上我們知道他是信號量的意思。在java中,一個計數(shù)信號量維護了一個許可集。Semaphore 只對可用許可的號碼進行計數(shù),并采取相應(yīng)的行動。拿到信號量的線程可以進入代碼,否則就等待。通過acquire()和release()獲取和釋放訪問許可。
信號量Semaphore是一個控制訪問多個共享資源的計數(shù)器,它本質(zhì)上是一個“共享鎖”。
Java并發(fā)提供了兩種加鎖模式:共享鎖和獨占鎖。前面介紹的ReentrantLock就是獨占鎖。對于獨占鎖而言,它每次只能有一個線程持有,而共享鎖則不同,它允許多個線程并行持有鎖,并發(fā)訪問共享資源。
獨占鎖它所采用的是一種悲觀的加鎖策略, 對于寫而言為了避免沖突獨占是必須的,但是對于讀就沒有必要了,因為它不會影響數(shù)據(jù)的一致性。如果某個只讀線程獲取獨占鎖,則其他讀線程都只能等待了,這種情況下就限制了不必要的并發(fā)性,降低了吞吐量。而共享鎖則不同,它放寬了加鎖的條件,采用了樂觀鎖機制,它是允許多個讀線程同時訪問同一個共享資源的。
舉一個生活中的例子,有一條單行道路口有一紅綠燈在正常的綠燈時間內(nèi)如果騎車速度都很平均只能過去20輛車,這就意味著排在前面的20輛肯定能過去紅綠燈,后面的就只能等下一個綠燈了。但是如果這個時候有車不想過去這個路口它駛向了邊上別的路,那么后面的車就有機會。下面我們來看一個簡單的例子:
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()+'個許可可用'); } catch (InterruptedException e) { e.printStackTrace(); } } } System.out.println('最后還有'+semaphore.availablePermits()+'個許可可用'); } } 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的詳細內(nèi)容,更多關(guān)于JAVA Semaphore的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. 如何基于python3和Vue實現(xiàn)AES數(shù)據(jù)加密2. 10個提供免費PHP腳本下載的網(wǎng)站3. PHP擴展之APC——Alternative PHP Cache(可選PHP緩存)4. PHP設(shè)計模式(四)原型模式Prototype實例詳解【創(chuàng)建型】5. Java 基于UDP協(xié)議實現(xiàn)消息發(fā)送6. Python編寫nmap掃描工具7. Java向Runnable線程傳遞參數(shù)方法實例解析8. python 爬取嗶哩嗶哩up主信息和投稿視頻9. ASP.NET MVC前臺動態(tài)添加文本框并在后臺使用FormCollection接收值10. php5.6不能擴展redis.so的解決方法
