<kbd id="afajh"><form id="afajh"></form></kbd>
<strong id="afajh"><dl id="afajh"></dl></strong>
    <del id="afajh"><form id="afajh"></form></del>
        1. <th id="afajh"><progress id="afajh"></progress></th>
          <b id="afajh"><abbr id="afajh"></abbr></b>
          <th id="afajh"><progress id="afajh"></progress></th>

          別再和面試官說(shuō)不懂信號(hào)量Semaphore了!

          共 1731字,需瀏覽 4分鐘

           ·

          2021-04-30 13:17


            點(diǎn)擊上方“JavaEdge”,關(guān)注公眾號(hào)

          設(shè)為“星標(biāo)”,好文章不錯(cuò)過(guò)!

          已經(jīng)習(xí)慣了阿里面試官的冷笑:用過(guò)Semaphore吧,不妨說(shuō)說(shuō)?


          本質(zhì)就是 信號(hào)量模型,模型圖如下:

          其中的 計(jì)數(shù)器 和 等待隊(duì)列 對(duì)外部是透明的,僅能通過(guò)提供的三大方法訪問(wèn)它們。

          詳細(xì)說(shuō)說(shuō)哪三大方法?

          • init()

            用于設(shè)置計(jì)數(shù)器的初始值。

          • down()

            計(jì)數(shù)器-1。若此時(shí)計(jì)數(shù)器<0,則當(dāng)前線程被 阻塞

          • up()

            計(jì)數(shù)器+1。若此時(shí)計(jì)數(shù)器≤0,則喚醒 等待隊(duì)列 中的一個(gè)線程,并將其從【等待隊(duì)列】移除。有同學(xué)可能會(huì)認(rèn)為這里的判斷條件應(yīng)該≥0,估計(jì)你是理解成生產(chǎn)者-消費(fèi)者模式中的生產(chǎn)者了??梢苑催^(guò)來(lái)想,>0 意味著沒(méi)有阻塞的線程,所以只有 ≤0 時(shí)才需要喚醒一個(gè)等待的線程。

          down()、up()應(yīng)配對(duì)使用,并按序使用:

          1. 先調(diào)用down(),獲取鎖

          2. 執(zhí)行處理完后,調(diào)用up(),釋放鎖

          若信號(hào)量init值為1,并發(fā)場(chǎng)景下應(yīng)該不會(huì)出現(xiàn)>0情況,除非故意調(diào)先用up(),但這也失去了信號(hào)量的意義。

          注意,這些方法都是原子性的,由信號(hào)量模型的實(shí)現(xiàn)方保證。JDK里的信號(hào)量模型就是由Semaphore實(shí)現(xiàn),Semaphore保證了這三個(gè)方法都是原子操作。

          talk is cheap,show me code?


          信號(hào)量模型中的down()、up()最早被稱(chēng)為P操作和V操作,信號(hào)量模型也稱(chēng)PV原語(yǔ)。還有的人會(huì)用semWait()和semSignal()表達(dá)它們,叫法不同,語(yǔ)義都相同。JUC的acquire()、release()分別對(duì)應(yīng)down()和up()。

          如何使用信號(hào)量?

          就像信號(hào)燈,必須先檢查是否為綠燈才能通過(guò)。比如累加器,count+=1操作是個(gè)臨界區(qū),只允許一個(gè)線程執(zhí)行,也就是說(shuō)要保證互斥。  

          假設(shè)線程t1、t2同時(shí)訪問(wèn)add(),當(dāng)同時(shí)調(diào)用acquire時(shí),由于acquire是個(gè)原子操作,僅會(huì)有一個(gè)線程(假設(shè)t1)把信號(hào)量里的計(jì)數(shù)器減為0,t2則是將計(jì)數(shù)器減為-1:

          • 對(duì)t1,信號(hào)量里面的計(jì)數(shù)器的值是0,≥0,所以t1不會(huì)被阻塞,而是繼續(xù)執(zhí)行

          • 對(duì)t2,信號(hào)量里面的計(jì)數(shù)器的值是-1,<0,所以t2被阻塞

          所以此時(shí)只有t1會(huì)進(jìn)入臨界區(qū)執(zhí)行count+=1。

          當(dāng)t1執(zhí)行release(),信號(hào)量里計(jì)數(shù)器的值是-1,加1之后的值是0,≤0,根據(jù)up(),此時(shí)等待隊(duì)列中的t2會(huì)被喚醒。于是t2在t1執(zhí)行完臨界區(qū)代碼后,才獲得進(jìn)入臨界區(qū)執(zhí)行的機(jī)會(huì),這就保證了互斥。

          既然有JDK提供了Lock,為啥還要提供一個(gè)Semaphore ?

          實(shí)現(xiàn)互斥鎖,僅是 Semaphore的部分功能,Semaphore還可以允許多個(gè)線程訪問(wèn)一個(gè)臨界區(qū)。

          最常見(jiàn)的就是各種池化資源,比如數(shù)據(jù)庫(kù)連接池,同一時(shí)刻,允許多個(gè)線程同時(shí)使用連接池。每個(gè)連接在被釋放前,不允許其他線程使用。

          對(duì)象池要求一次性創(chuàng)建出N個(gè)對(duì)象,之后所有的線程重復(fù)利用這N個(gè)對(duì)象,當(dāng)然對(duì)象在被釋放前,也是不允許其他線程使用的。所以核心就是限流器,這里的限流指不允許多于N個(gè)線程同時(shí)進(jìn)入臨界區(qū)。

          如何快速實(shí)現(xiàn)一個(gè)這樣的限流器呢?

          那就是信號(hào)量。把計(jì)數(shù)器的值設(shè)置成對(duì)象池里對(duì)象的個(gè)數(shù)N即可: 注意這里使用的是 Vector,進(jìn)入臨界區(qū)的N個(gè)線程不安全。add/remove都是不安全的。比如 ArrayList remove() :


          好的,請(qǐng)回家等通知吧


          往期推薦


          由于不知線程池的bug,某Java程序員叕被祭天

          程序員因重復(fù)記錄日志撐爆ELK被辭退!

          擁抱Kubernetes,再見(jiàn)了Spring Cloud

          和阿里P8大佬面試互懟了半小時(shí)的Fork/Join原理!




          目前交流群已有 800+人,旨在促進(jìn)技術(shù)交流,可關(guān)注公眾號(hào)添加筆者微信邀請(qǐng)進(jìn)群



          喜歡文章,點(diǎn)個(gè)“在看、點(diǎn)贊、分享”素質(zhì)三連支持一下~

          瀏覽 65
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報(bào)
          評(píng)論
          圖片
          表情
          推薦
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報(bào)
          <kbd id="afajh"><form id="afajh"></form></kbd>
          <strong id="afajh"><dl id="afajh"></dl></strong>
            <del id="afajh"><form id="afajh"></form></del>
                1. <th id="afajh"><progress id="afajh"></progress></th>
                  <b id="afajh"><abbr id="afajh"></abbr></b>
                  <th id="afajh"><progress id="afajh"></progress></th>
                  手机在线永久免费观看AV片 | 国产成人三级在线观看视频 | 欧美成人猛片AAAAAAA | 成人激情站,开心五月天 | 天天好逼网综合 |