cocurrent包semaphore信号量
?
semaphore
英[?sem?f?:(r)]
美[?s?m??f?r, -?for]
n. 臂板信號(hào)系統(tǒng),(鐵道)臂板信號(hào)裝置;
?
?
Semaphore 用法
信號(hào)量主要有兩種用途:
保護(hù)重要部分
如果你將信號(hào)量用于保護(hù)一個(gè)重要部分,試圖進(jìn)入這一部分的代碼通常會(huì)首先嘗試獲得一個(gè)許可,然后才能進(jìn)入重要部分(代碼塊),執(zhí)行完之后,再把許可釋放掉。比如這樣:
[java]?view plaincopy?
在線(xiàn)程之間發(fā)送信號(hào)
如果你將一個(gè)信號(hào)量用于在兩個(gè)線(xiàn)程之間傳送信號(hào),通常你應(yīng)該用一個(gè)線(xiàn)程調(diào)用 acquire() 方法,而另一個(gè)線(xiàn)程調(diào)用 release() 方法。
如果沒(méi)有可用的許可,acquire() 調(diào)用將會(huì)阻塞,直到一個(gè)許可被另一個(gè)線(xiàn)程釋放出來(lái)。同理,如果無(wú)法往信號(hào)量釋放更多許可時(shí),一個(gè) release() 調(diào)用也會(huì)阻塞。
通過(guò)這個(gè)可以對(duì)多個(gè)線(xiàn)程進(jìn)行協(xié)調(diào)。比如,如果線(xiàn)程 1 將一個(gè)對(duì)象插入到了一個(gè)共享列表(list)之后之后調(diào)用了 acquire(),而線(xiàn)程 2 則在從該列表中獲取一個(gè)對(duì)象之前調(diào)用了 release(),這時(shí)你其實(shí)已經(jīng)創(chuàng)建了一個(gè)阻塞隊(duì)列。信號(hào)量中可用的許可的數(shù)量也就等同于該阻塞隊(duì)列能夠持有的元素個(gè)數(shù)。
公平
沒(méi)有辦法保證線(xiàn)程能夠公平地可從信號(hào)量中獲得許可。也就是說(shuō),無(wú)法擔(dān)保掉第一個(gè)調(diào)用 acquire() 的線(xiàn)程會(huì)是第一個(gè)獲得一個(gè)許可的線(xiàn)程。如果第一個(gè)線(xiàn)程在等待一個(gè)許可時(shí)發(fā)生阻塞,而第二個(gè)線(xiàn)程前來(lái)索要一個(gè)許可的時(shí)候剛好有一個(gè)許可被釋放出來(lái),那么它就可能會(huì)在第一個(gè)線(xiàn)程之前獲得許可。
如果你想要強(qiáng)制公平,Semaphore 類(lèi)有一個(gè)具有一個(gè)布爾類(lèi)型的參數(shù)的構(gòu)造子,通過(guò)這個(gè)參數(shù)以告知 Semaphore 是否要強(qiáng)制公平。強(qiáng)制公平會(huì)影響到并發(fā)性能,所以除非你確實(shí)需要它否則不要啟用它。
以下是如何在公平模式創(chuàng)建一個(gè) Semaphore 的示例:
?
更多方法
java.util.concurrent.Semaphore 類(lèi)還有很多方法,比如:
- availablePermits()
- acquireUninterruptibly()
- drainPermits()
- hasQueuedThreads()
- getQueuedThreads()
- tryAcquire()
- 等等
這些方法的細(xì)節(jié)請(qǐng)參考 Java 文檔。
?
轉(zhuǎn)載于:https://www.cnblogs.com/panxuejun/p/8566027.html
總結(jié)
以上是生活随笔為你收集整理的cocurrent包semaphore信号量的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Javascript之 对象和原型
- 下一篇: 删除搜索记录