java Semaphore信号灯

Semaphore实现的功能就类似2个公用电话，假如有10个人要打电话；那么只能2个人占有电话，8个需要等待。
当2个人中的任何一个人让开后，其中等待的另外8个人中又有一个人可以使用了
等待的8个人中可以是随机获得优先机会，也可以是按照先来后到的顺序获得机会，这取决于构造Semaphore对象时传入的参数选项。
单个信号量的Semaphore对象可以实现互斥锁的功能，并且可以是由一个线程获得了锁，再由另一个线程释放锁，这可应用于死锁恢复的一些场合。
Semaphore维护了当前访问的个数，提供同步机制，控制同时访问的个数。
Semaphore可以控制某个资源可被同时访问的个数，通过 acquire() 获取一个许可通过release() 释放一个许可

案例：

public class SemaphoreTest{
    public static void main(String[] args) {
        ExecutorService pool = Executors.newCachedThreadPool();
        //2个公用电话  可以通过true/false决定获取许可证顺序
        final  Semaphore sp = new Semaphore(2,true);
        //10个需要打电话
        for(int i=1;i<=10;i++){
            Runnable runnable = new Runnable(){
                public void run(){
                    try {
                        sp.acquire();
                    } catch (InterruptedException e1) {}

                    System.out.println("线程" + Thread.currentThread().getName() + "获取通话，当前还有" + sp.availablePermits()+ "个电话可以用");

                    try {
                        Thread.sleep((long)(Math.random()*1000));
                    } catch (InterruptedException e) {}
                    System.out.println("线程" + Thread.currentThread().getName() + "即将离开 ");
                    sp.release();
                }
            };
            pool.execute(runnable);
        }
        pool.shutdown();
    }
}

结果输出：

线程pool-1-thread-1获取通话，当前还有0个电话可以用
线程pool-1-thread-3获取通话，当前还有0个电话可以用
线程pool-1-thread-3即将离开
线程pool-1-thread-5获取通话，当前还有0个电话可以用
线程pool-1-thread-1即将离开
线程pool-1-thread-2获取通话，当前还有0个电话可以用
线程pool-1-thread-2即将离开
线程pool-1-thread-7获取通话，当前还有0个电话可以用
线程pool-1-thread-5即将离开
线程pool-1-thread-6获取通话，当前还有0个电话可以用
线程pool-1-thread-7即将离开
线程pool-1-thread-9获取通话，当前还有0个电话可以用
线程pool-1-thread-6即将离开
线程pool-1-thread-4获取通话，当前还有0个电话可以用
线程pool-1-thread-9即将离开
线程pool-1-thread-10获取通话，当前还有0个电话可以用
线程pool-1-thread-10即将离开
线程pool-1-thread-8获取通话，当前还有0个电话可以用
线程pool-1-thread-4即将离开
线程pool-1-thread-8即将离开

秒客网

java Semaphore信号灯

相关文章