Semaphore信號(hào)量的核心是用 N 張“許可證”限制同時(shí)訪問資源的線程數(shù)——線程進(jìn)來先 acquire() 拿一張用完 release() 還回去許可證發(fā)完了后面的線程就得排隊(duì)。下面給你 Java 最常用版本的可運(yùn)行示例。核心概念初始化時(shí)指定許可證數(shù)量 N相當(dāng)于“最多允許 N 個(gè)線程同時(shí)進(jìn)臨界區(qū)”acquire()拿許可證沒有就阻塞等待release()還許可證務(wù)必放在finally或使用with否則忘了釋放就會(huì)死鎖tryAcquire()非阻塞版本拿不到立刻返回false適合做限流降級(jí)importjava.util.concurrent.Semaphore;publicclassSemaphoreDemo{// 許可證數(shù)量為 3即同時(shí)最多 3 個(gè)線程能進(jìn)臨界區(qū)privatestaticfinalSemaphoresemaphorenewSemaphore(3);publicstaticvoidmain(String[]args){for(inti1;i5;i){newThread(newTask(線程-i)).start();}}staticclassTaskimplementsRunnable{privatefinalStringname;Task(Stringname){this.namename;}Overridepublicvoidrun(){try{semaphore.acquire();// 拿許可證沒有就阻塞System.out.println(name 進(jìn)入臨界區(qū)當(dāng)前可用許可證: semaphore.availablePermits());Thread.sleep(2000);// 模擬業(yè)務(wù)耗時(shí)System.out.println(name 執(zhí)行完畢);}catch(InterruptedExceptione){e.printStackTrace();}finally{semaphore.release();// 一定要釋放System.out.println(name 釋放許可證);}}}}運(yùn)行后會(huì)看到前 3 個(gè)線程同時(shí)進(jìn)入后 2 個(gè)等前面有人釋放后才依次進(jìn)入。線程-1 進(jìn)入臨界區(qū)當(dāng)前可用許可證:2線程-4 進(jìn)入臨界區(qū)當(dāng)前可用許可證:0線程-3 進(jìn)入臨界區(qū)當(dāng)前可用許可證:1線程-1 執(zhí)行完畢 線程-4 執(zhí)行完畢 線程-3 執(zhí)行完畢 線程-4 釋放許可證 線程-3 釋放許可證 線程-1 釋放許可證 線程-5 進(jìn)入臨界區(qū)當(dāng)前可用許可證:1線程-2 進(jìn)入臨界區(qū)當(dāng)前可用許可證:2線程-5 執(zhí)行完畢 線程-5 釋放許可證 線程-2 執(zhí)行完畢 線程-2 釋放許可證 進(jìn)程已結(jié)束退出代碼為0 典型應(yīng)用場景對比場景許可證數(shù)量說明數(shù)據(jù)庫連接池連接數(shù)上限例如設(shè)置 10防止連接耗盡API 接口限流QPS 上限例如設(shè)置 50保護(hù)后端服務(wù)爬蟲并發(fā)控制目標(biāo)站承受力避免請求過快被封 IP互斥鎖Mutex*1等同于Lock實(shí)現(xiàn)線程獨(dú)占?? 注意事項(xiàng)死鎖風(fēng)險(xiǎn)如果acquire()后未調(diào)用release()如異常中斷會(huì)導(dǎo)致永久阻塞。公平性Java 構(gòu)造器new Semaphore(3, true)可設(shè)置為公平模式FIFO但會(huì)降低性能。Asyncio 作用域asyncio.Semaphore必須在async def函數(shù)內(nèi)創(chuàng)建不能在模塊頂層創(chuàng)建會(huì)報(bào) Event Loop 錯(cuò)誤。