跑起一个程序，并不难；难的是，能让程序跑多远！—— 一颗剽悍的种子

JUC并发系列

JUC并发系列(一)：什么？听说你搞混了并发和并行
JUC并发系列(二)：详解Condition实现精准通知唤醒
JUC并发系列(三)：面试问并发，一问锁就懵（怒肝一篇透彻理解锁，面试不慌）
JUC并发系列(四)：【面试常问】多种方法解决ArrayList非线程安全，详解CopyOnWriteArrayList
JUC并发系列(五)：CopyOnWriteArraySet解决HashSet非线程安全
JUC并发系列(六)：ConcurrentHashMap解决HashMap非线程安全
JUC并发系列(七)：触及Callable
JUC并发系列(八)：并发编程常用辅助类CountDownLatch与CyclicBarrier

系列八展开了并发编程常用辅助类CountDownLatch和CyclicBarrier，其实还有第三个常用辅助类Semaphore。

JUC并发系列(八)：并发编程常用辅助类CountDownLatch与CyclicBarrier

一、什么是 Semaphore？

Semaphore 信号量，用来控制同时访问资源的线程数，可以通过协调各个线程确保合理使用资源。

二、应用场景

Semaphore用于多个公共共享资源互斥，以及有限公用资源流量控制的运用。

三、举一个栗子

举一个现实当中我们上厕所的例子，例如房子里只有两间厕所，那么就只允许同时有两个人进去使用，其他人都必须在厕所外等待，所以前两人会先使用厕所，后面的人看到厕所关着门有人使用，也就不能再使用；但是前两人一旦有一人已经离开厕所，那么后面就允许有一人进去使用。

这个例子的人是线程，而厕所关着有人使用表示线程在执行，离开厕所表示线程执行完成；看到厕所关着有人使用表示线程阻塞，不能执行。

四、关键代码

跟我们讲CountDownLatch和CyclicBarrier的count同样放的是线程数量，不同的是这里count用的是 限流。

Semaphore semphore = new Semaphore(int count);

acquire() 获取到信号量，当信号量满时就等待，直到释放。

semphore.acquire();

release() 释放信号量，将信号量释放，然后唤醒等待的线程。

semphore.release();

五、手敲代码示例

看完上面的例子我们来实践一下，还是两间厕所，有6个人需要使用。

public class Demo{ 
    public static void main(String[] args) { 
        Semaphore semphore = new Semaphore(2);
        for (int i = 1; i <= 6; i++) { 
            new Thread(()->{ 
                try { 
                    semphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "进厕所");
                    TimeUnit.SECONDS.sleep(3);
                    System.out.println(Thread.currentThread().getName() + "离开厕所");
                } catch (InterruptedException e) { 
                    e.printStackTrace();
                }finally { 
                    semphore.release();
                }
            }).start();
        }
    }
}

六、运行结果

可以看到只有在 Semaphore 规定的线程数量下有秩序的执行。

七、最后

最后的最后，为了更好的阅读体验，我把想说的话都放在了下面，嘿嘿。

我是一颗剽悍的种子 把我会的，认真的分享 是我写博客一直不变的信条。
如果你能看到这篇博文，说明咱们还是很有缘的；希望能带给你一些许帮助，创作的不易， 把我文章的知识带走，你的三连留下，点赞，评论，关注，是我最大的动力。