Semaphore信號量的核心是用 N 張“許可證”限制同時訪問資源的線程數(shù)——線程進(jìn)來先 acquire() 拿一張用完 release() 還回去許可證發(fā)完了后面的線程就得排隊。下面給你 Java 最常用版本的可運(yùn)行示例。核心概念初始化時指定許可證數(shù)量 N相當(dāng)于“最多允許 N 個線程同時進(jìn)臨界區(qū)”acquire()拿許可證沒有就阻塞等待release()還許可證務(wù)必放在finally或使用with否則忘了釋放就會死鎖tryAcquire()非阻塞版本拿不到立刻返回false適合做限流降級importjava.util.concurrent.Semaphore;publicclassSemaphoreDemo{// 許可證數(shù)量為 3即同時最多 3 個線程能進(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ù)耗時System.out.println(name 執(zhí)行完畢);}catch(InterruptedExceptione){e.printStackTrace();}finally{semaphore.release();// 一定要釋放System.out.println(name 釋放許可證);}}}}運(yùn)行后會看到前 3 個線程同時進(jìn)入后 2 個等前面有人釋放后才依次進(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實現(xiàn)線程獨(dú)占?? 注意事項死鎖風(fēng)險如果acquire()后未調(diào)用release()如異常中斷會導(dǎo)致永久阻塞。公平性Java 構(gòu)造器new Semaphore(3, true)可設(shè)置為公平模式FIFO但會降低性能。Asyncio 作用域asyncio.Semaphore必須在async def函數(shù)內(nèi)創(chuàng)建不能在模塊頂層創(chuàng)建會報 Event Loop 錯誤。