Java中的Semaphore信号量深入解析

Semaphore(int permits) //非公平模式指定最大允许访问许可证数量
Semaphore(int permits, boolean fair)//可以通过第二个参数控制是否使用公平模

acquire() //申请获取一个许可证，如果没有许可证，就阻塞直到能够获取或者被打断
availablePermits() // 返回当前有多少个有用的许可证数量hasQueuedThreads()//查询是否有线程正在等待获取许可证
drainPermits()//获得并返回所有立即可用的许可证数量
getQueuedThreads()//返回一个List包含当前可能正在阻塞队列里面所有线程对象
getQueueLength()//返回当前可能在阻塞获取许可证线程的数量
hasQueuedThreads()//查询是否有线程正在等待获取许可证
isFair()//返回是否为公平模式
reducePermits(int reduction)//减少指定数量的许可证
reducePermits(int reduction)//释放一个许可证
release(int permits)//释放指定数量的许可证
tryAcquire()//非阻塞的获取一个许可证

public class SemaphoreDemo2 {
 
    private final Lock lock=new ReentrantLock(true);
    private final Condition condition=lock.newCondition();
    private int permit;
    public SemaphoreDemo2(int permit) {
        this.permit=permit;
    }
 
 
    private void acquire(){
 
        lock.lock();
        try{
            if(permit==0){
                condition.await();//如果超过限制，就进入条件阻塞队列
            }
            System.out.println(Thread.currentThread().getName()+"  获得资源 .... ");
             permit--;
 
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
 
    }
 
 
    private void  release(){
        lock.lock();
        try{
            permit++;
            condition.signalAll(); //每当有一个释放令牌，就唤醒所有等待的线程
        }finally {
            lock.unlock();
        }
 
 
    }
 
 
}

Semaphore semaphore=new Semaphore(3);
 
        Runnable runnable=new Runnable() {
            @Override
            public void run() {
                try {
                    semaphore.acquire();
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + " 访问资源......");
                    semaphore.release();
            }
        };
 
        for (int i = 0; i < 5; i++) {
            Thread thread=new Thread(runnable);
            thread.start();
        }
 
        Thread.sleep(3000);