Semaphore

　　Semaphore也叫信號量，在JDK1.5被引入，用來控制同時訪問某個特定資源的操作數量，或者同時執行某個指定操作的數量。還可以用來實現某種資源池，或者對容器施加邊界。

　　Semaphore內部維護了一組虛擬的許可，許可的數量可以通過構造函數的參數指定。

　　訪問特定資源前，必須使用acquire方法獲得許可，如果許可數量為0，該線程則一直阻塞，直到有可用許可。

　　訪問資源后，使用release釋放許可。

 

　　Semaphore和ReentrantLock類似，獲取許可有公平策略和非公平許可策略，默認情況下使用非公平策略。

　　當初始值為1時，可以用作互斥鎖，並具備不可重入的加鎖語義。

　　Semaphore將AQS的同步狀態用於保存當前可用許可的數量。

 

實現資源池：

　　一個固定長度的資源池，當池為空時，請求資源會失敗。

　　使用Semaphore可以實現當池為空時，請求會阻塞，非空時解除阻塞。

　　也可以使用Semaphore將任何一種容器變成有界阻塞容器。

 

 

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;


public class SemaPhore {
    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() * 6000));
                        // 訪問完后，釋放
                        semp.release();
                        //availablePermits()指還剩多少個許可
                        System.out.println("-----------------" + semp.availablePermits()); 
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            };
            exec.execute(run);
        }
        // 退出線程池
        exec.shutdown();
    }
}