Java之多線程 Semaphore（信號量）

  一個計數信號量。從概念上講，信號量維護了一個許可集。若有必要，在許可可用前會阻塞每個 acquire()，而後再獲取該許可。每一個 release() 添加一個許可，從而可能釋放一個正在阻塞的獲取者。可是，不使用實際的許可對象，Semaphore 只對可用許可的號碼進行計數，並採起相應的行動。拿到信號量的線程能夠進入代碼，不然就等待。經過acquire()和release()獲取和釋放訪問許可。

 

相關方法：

acquire

public void acquire()
             throws InterruptedException

今後信號量獲取一個許可，在提供一個許可前一直將線程阻塞，不然線程被 中斷。獲取一個許可（若是提供了一個）並當即返回，將可用的許可數減 1。

 

若是沒有可用的許可，則在發生如下兩種狀況之一前，禁止將當前線程用於線程安排目的並使其處於休眠狀態：

• 某些其餘線程調用此信號量的 release() 方法，而且當前線程是下一個要被分配許可的線程；或者
• 其餘某些線程中斷當前線程。

若是當前線程：

• 被此方法將其已中斷狀態設置爲 on ；或者
• 在等待許可時被中斷。

則拋出 InterruptedException，而且清除當前線程的已中斷狀態。

拋出：

InterruptedException - 若是當前線程被中斷

release

public void release()

釋放一個許可，將其返回給信號量。釋放一個許可，將可用的許可數增長 1。若是任意線程試圖獲取許可，則選中一個線程並將剛剛釋放的許可給予它。而後針對線程安排目的啓用（或再啓用）該線程。

 

不要求釋放許可的線程必須經過調用 acquire() 來獲取許可。經過應用程序中的編程約定來創建信號量的正確用法。

 

相關例子：

 

下面的例子只容許5個線程同時進入執行acquire()和release()之間的代碼：

public class SemaphoreTest {

     public static void main(String[] args) {  
        // 線程池 
        ExecutorService exec = Executors.newCachedThreadPool();  
        // 只能5個線程同時訪問 
        final Semaphore semp = new Semaphore(5);  
        // 模擬20個客戶端訪問 
        for (int index = 0; index < 20; index++) {
            final int NO = index;  
            Runnable run = new Runnable() {  
                public void run() {  
                    try {  
                        // 獲取許可 
                        semp.acquire();  
                        System.out.println("Accessing: " + NO);  
                        Thread.sleep((long) (Math.random() * 10000));  
                        // 訪問完後，釋放 ，若是屏蔽下面的語句，則在控制檯只能打印5條記錄，以後線程一直阻塞
                        semp.release();  
                    } catch (InterruptedException e) {  
                    }  
                }  
            };  
            exec.execute(run);  
        }  
        // 退出線程池 
        exec.shutdown();  
    }  
}