并发编程(九)并发工具类CyclicBarrier,CountDownLatch,Semaphore

2021-09-21 13:04:24 阅读：192 来源： 互联网

标签：获取马路 tryAcquire 并发线程 Semaphore static CyclicBarrier

Semaphore

用来控制同时访问特定资源的线程数量，通过协调保证合理的使用公共资源
理解比作控制车流的红绿灯，如马路要控制流量，只限制100辆车通行，其他必须在路口处等待，不能行驶在马路上，当其中有5辆离开马路，那么允许后面5辆进入马路。例子中的车就是线程，驶入马路表示线程正在执行，离开马路表示线程执行完成，看见红灯表示被阻塞。

public class SemaphoreTest {
    private static final int THREAD_COUNT = 30;

    private static ExecutorService pool = Executors.newFixedThreadPool(THREAD_COUNT);

    private static Semaphore s = new Semaphore(10);  // 最多只有10个线程能同时访问资源

    public static void main(String[] args) {
        for (int i = 0; i < THREAD_COUNT; i++) {
            pool.execute(new Runnable() {
                @Override
                public void run() {
                    /**
                     * 1: acquire()  一次获取一个许可 凭证就能往下走  抛出中断异常
                     *                 还有一个函数acquire(int permit) 表示一个线程获取permit个许可凭证才能
                     *                 往下走
                     *                 s.acquireUninterruptibly();  //中断不抛出异常
                     */
                    try {
                        s.acquire();   //获取资源许可证，如果还有资源可以访问
                                        // 就是通过CAS 把资源state-1,成功了就往下走
                                        // 失败了就阻塞，支持中断，抛出一个异常

                        System.out.println("do something");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    /**
                     * 2: tryAcquire()  尝试获取凭证，获取不到就返回不会阻塞
                     *  s.tryAcquire(2, TimeUnit.MILLISECONDS);  如果获取不到凭证就等待一定时间 超时就返回
                     *    可以用这种方式做服务降级，Hystrix中的限流就是基于这个信号量
                     */
                    s.tryAcquire();
//                  s.tryAcquire(2, TimeUnit.MILLISECONDS);

                    try {
                        if (s.tryAcquire(2, TimeUnit.MILLISECONDS)){
                            System.out.println("获取到凭证执行");
                        }else {
                            System.out.println("获取不到进行服务降级");
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        } 
}

CountDownLatch的用法：

参考博文：https://www.cnblogs.com/Lee_xy_z/p/10470181.html

使用场景还有Zookeeper分布式锁，Jmeter模拟高并发

CyclicBarrier 用法

参见：https://blog.csdn.net/fu123123fu/article/details/103731228

标签：获取,马路,tryAcquire,并发,线程,Semaphore,static,CyclicBarrier
来源： https://www.cnblogs.com/krock/p/15316397.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

并发编程(九)并发工具类CyclicBarrier,CountDownLatch,Semaphore

Semaphore

CyclicBarrier 用法