日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪(fǎng)問(wèn) 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

cocurrent包semaphore信号量

發(fā)布時(shí)間:2025/3/15 编程问答 24 豆豆
生活随笔 收集整理的這篇文章主要介紹了 cocurrent包semaphore信号量 小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

?

semaphore
英[?sem?f?:(r)]
美[?s?m??f?r, -?for]
n. 臂板信號(hào)系統(tǒng),(鐵道)臂板信號(hào)裝置;

?

?

Semaphore 用法

信號(hào)量主要有兩種用途:

  • 保護(hù)一個(gè)重要(代碼)部分防止一次超過(guò) N 個(gè)線(xiàn)程進(jìn)入。
  • 在兩個(gè)線(xiàn)程之間發(fā)送信號(hào)。
  • 保護(hù)重要部分

    如果你將信號(hào)量用于保護(hù)一個(gè)重要部分,試圖進(jìn)入這一部分的代碼通常會(huì)首先嘗試獲得一個(gè)許可,然后才能進(jìn)入重要部分(代碼塊),執(zhí)行完之后,再把許可釋放掉。比如這樣:

    [java]?view plaincopy
  • Semaphore?semaphore?=?new?Semaphore(1);??
  • ??
  • //critical?section??
  • semaphore.acquire();??
  • ??
  • ...??
  • ??
  • semaphore.release();??
  • ?

    在線(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]?view plaincopy
  • Semaphore?semaphore?=?new?Semaphore(1,?true);??
  • ?

    更多方法

    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)題。

    如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò),歡迎將生活随笔推薦給好友。