Semaphore

超、凢脫俗 2023-02-20 10:48 18阅读 0赞

Semaphone是一个信号量，它控制的是线程并发的数量，必须由获取它的线程释放。常用于限制可以访问某些资源的线程数量，例如通过 Semaphore 限流。**看到这里的话，如果不是很理解前面这段话是什么意思，可以先去看看案例代码展示部分，看完后再回头来看看这句话就会有一个新的比较清晰的认识。**

Semaphone只有3个操作：

1.初始化

Semaphore semaphore = new Semaphore(3);

2.增加

//释放许可
    semaphore.release();

3.减少

//获取许可
    semaphore.acquire()

案例代码展示：

package com.bc.test;
    
    import java.util.Random;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Semaphore;
    
    public class SemaphoreDemo {
    
        public static void main(String[] args){
            ExecutorService executorService=Executors.newCachedThreadPool();
    
            //信号量，只允许3个线程同时访问
            final Semaphore semaphore=new Semaphore(3);
    
            for(int i=0;i<10;i++){
                final long num=i;
                executorService.submit(new Runnable() {
                    public void run() {
                        try{
                            //获取许可
                            semaphore.acquire();
                            //执行
                            System.out.println("Accessing:"+num);
                            Thread.sleep(new Random().nextInt(5000));//模拟随机执行时长
                            //释放
                            semaphore.release();
                            System.out.println("Release..."+num);
                        }catch (Exception e){
                            e.printStackTrace();
                        }
                    }
                });
            }
            executorService.shutdown();
        }
    }

执行结果如下：

![20200626112247860.png][]

结果解释：此处我们先使用了for循环，提交了10个任务到线程池中，线程池中此时具有10个线程。首先是线程池中的线程0、2、1获取到了信号量，其它的线程此时处于阻塞状态。接着线程2释放了信号量，线程3获取到了信号量，此时拥有信号量的线程为0、1、3，那么接下来可能会释放信号量的只能是这三个线程（线程0、1、3）中的某一个线程，从打印结果可以看出在线程3获取到了信号量后，线程1释放了信号量。依次类推，最多允许3个线程同时获得信号量去执行业务逻辑。

[20200626112247860.png]: https://img-blog.csdnimg.cn/20200626112247860.png