JUC--Semaphore简介和使用

1 概述

通过查看JDK的API,我们可以发现对Semaphore的定义如下:

信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个 acquire(),然后再获取该许可。每个 release() 添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,Semaphore 只对可用许可的号码进行计数,并采取相应的行动。

Semaphore(信号量)限制着访问某些资源的线程数量,在到达限制的线程数量之前,线程能够继续进行资源的访问,一旦访问资源的数量到达限制的线程数量,这个时候线程就不能够再去获取资源,只有等待有线程退出资源的获取。

2 示例

接下来我们来看一看Semphore是如何使用的:

/**
 * 演示信号量Semaphore的使用
 * @author: LIUTAO
 * @Date: Created in 2018/9/3  10:12
 * @Modified By:
 */
public class SemaphoreDemo {
    static final Semaphore semp = new Semaphore(5);
    public static class SempDemo implements Runnable{

        @Override
        public void run() {
            try {

                //获取信号量许可
                semp.acquire();
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getId()+":done!");

                //释放信号量许可
                semp.release();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }



    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(20);
        final SempDemo sempDemo = new SempDemo();
        for (int i = 0;i<15;i++){
            executorService.submit(sempDemo);
        }
    }
}

运行上面的程序,输出如下:

13:done!
14:done!
16:done!
15:done!
17:done!
19:done!
18:done!
20:done!
21:done!
22:done!
24:done!
23:done!
26:done!
25:done!
27:done!

我们会发现上面的内容是5个一组进行输出的,为什么呢?这是由于所有的线程是在sleep相同的时间然后再一起释放许可的。这里我们就看出来了,虽然有20个线程,但是每次仅仅允许5个线程获得许可。

3 函数说明

acquire():获取许可,如果没有获取到则进行等待,直到获取到许可或者线程中断。

acquireUninterruptibly():获取许可,阻塞直到有许可可以使用,不响应线程中断。

acquire(int permits):获取指定数量的许可,阻塞直到指定数量的许可可以使用,响应线程中断。

acquireUninterruptibly(int permits):获取指定数量的许可,阻塞直到指定数量的许可可以使用,不响应线程中断。

release():释放许可。

release(int permits):释放指定数量的许可。

availablePermits():返回当前可以使用的许可数量。这个方法通常用于测试。

Semphore还有很多方法,我们可以查看源码了解。

接下来楼博主会继续学习并总结Semaphore的源码,欢迎阅读并指正。

 

    原文作者:JUC
    原文地址: https://blog.csdn.net/ONROAD0612/article/details/82463349
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞