Semaphore類介紹

A counting semaphore. Conceptually, a semaphore maintains a set of permits. Each acquire() blocks if necessary until a permit is available, and then takes it. Each release() adds a permit, potentially releasing a blocking acquirer. However, no actual permit objects are used; the Semaphore just keeps a count of the number available and acts accordingly.

從JavaDoc的釋義中我們可以總結如下幾點：
1. Semaphore是一個計數訊號量，允許n個任務同時訪問某個資源
2. 如果沒有達到可允許的執行緒數量，當前使用acquire()方法獲取許可，使用release()方法再訪問完後釋放許可
3. Semaphore並不存在真正的允許物件(permit objects),僅僅是維護了一個允許訪問的數量集

示例:

public class SemaphoreDemo {
    public static void main(String[] args) {
        final Semaphore semaphore = new
 
 Semaphore(2);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executorService.execute(new Runnable() {
                public void run() {
                    try {
                        semaphore.acquire();
                        // TODO:
 

                        System.out.println("執行緒:" + Thread.currentThread().getName() + "獲得許可:" + index);
                        TimeUnit.SECONDS.sleep(3);
                        semaphore.release();
                        System.out.println("允許TASK個數：" + semaphore.availablePermits());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }
        executorService.shutdown();
    }
}

建構函式

public Semaphore(int permits) {
    sync = new NonfairSync(permits);
}

permits引數表示許可數，也就是最大訪問執行緒數。permits引數一經初始化就不能修改

public Semaphore(int permits, boolean fair) {
    sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}

permits引數上面已介紹。
fair預設值為false.表示獲取許可的順序是無序的，也就是說新縣城可能會比等待的老執行緒會先獲得許可；當設定為true時，訊號量保證它們呼叫的順序級先進先出

常用方法

1. void acquire() 從訊號量獲取一個許可，如果無可用許可前 將一直阻塞等待
2. void acquire(int permits) 獲取指定數目的許可，如果無可用許可前 也將會一直阻塞等待
3. boolean tryAcquire() 從訊號量嘗試獲取一個許可，如果無可用許可，直接返回false，不會阻塞
4. boolean tryAcquire(int permits) 嘗試獲取指定數目的許可，如果無可用許可直接返回false，
5. boolean tryAcquire(int permits, long timeout, TimeUnit unit) 在指定的時間內嘗試從訊號量中獲取許可，如果在指定的時間內獲取成功，返回true，否則返回false
6. void release() 釋放一個許可，別忘了在finally中使用，注意：多次呼叫該方法，會使訊號量的許可數增加，達到動態擴充套件的效果，如：初始permits 為1， 呼叫了兩次release，最大許可會改變為2
7. int availablePermits() 獲取當前訊號量可用的許可