架構之路:深刻Semaphore

Semaphore(信號量)

注意了,外星人放出必定量的信號(permits),其餘外星人接到信號並使用(acquire),使用完後告訴發送人再也不使用了(release)。若是信號被用完,只能等待。數據庫

用途:多線程運行限流、流量控制、數據庫線程池控制、控制順序執行多線程

提供公平和非公平的兩種方式。ui

class ZeroEvenOdd {
    private int n;
    private Semaphore z = new Semaphore(1);
    private Semaphore e = new Semaphore(0);
    private Semaphore o = new Semaphore(0);
    public ZeroEvenOdd(int n) {
        this.n = n;
    }

    // printNumber.accept(x) outputs "x", where x is an integer.
    public void zero(IntConsumer printNumber) throws InterruptedException {
        for(int i = 0;i<n;i++){
            z.acquire();
            printNumber.accept(0);
            if(i%2 ==0){
                o.release();
            }else{
                e.release();
            }
        }
    }

    public void even(IntConsumer printNumber) throws InterruptedException {
        for(int i = 2;i <= n;i += 2){
            e.acquire();
            printNumber.accept(i);
            z.release();   
        }
    }

    public void odd(IntConsumer printNumber) throws InterruptedException {
        for(int i = 1;i<=n;i+=2){
            o.acquire();
            printNumber.accept(i);
            z.release();  
        }
    }
}

代碼中建立了1個信號,有3個對象共享。同一時間只有1個方法執行,默認z有許可證,用完後通知o和e釋放,拿到資源後繼續執行even或odd方法。this

 

其餘方法

Semaphore還提供一些其餘方法:spa

  • int availablePermits() :返回此信號量中當前可用的許可證數。
  • int getQueueLength():返回正在等待獲取許可證的線程數。
  • boolean hasQueuedThreads() :是否有線程正在等待獲取許可證。
  • void reducePermits(int reduction) :減小reduction個許可證。是個protected方法。
  • Collection getQueuedThreads() :返回全部等待獲取許可證的線程集合。是個protected方法。
相關文章
相關標籤/搜索