栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

浅谈Semaphore

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

浅谈Semaphore

文章目录
  • 一、Semaphore是什么?主要作用是什么?
  • 二、Semaphore的实现原理是什么?
  • 三、Semaphore的简单使用


一、Semaphore是什么?主要作用是什么?

Semaphore简称信号量,它是JUC包下面对限流提供的一种解决方案。也就是说使用它后,可以保证在同一时间内只能有规定数量的任务可以执行,其它任务进入等待状态。

二、Semaphore的实现原理是什么?

Semaphore的阻塞原理和ReentrantLock的阻塞原理类似,主要区别的地方有两点:

  • 1、Semaphore的state属性的值表示可以有多少个任务可以同时执行,所以该值是可以大于1的,比如state=5表明有五个任务可以同时执行。当有任务执行时state会减一,直至state减为-1表明信号通道已用完,其它任务进入双向链表(同步阻塞队列);
  • 2、Semaphore在释放锁并执行唤醒方法时会持续的进行唤醒(释放锁state加一、唤醒的线程获取锁时state减一),直至state的值为负一为止,也就是说Semaphore的唤醒会不断的往链表后方唤醒线程,直到唤醒的线程无法获取锁为止;
三、Semaphore的简单使用
static Semaphore semaphore = new Semaphore(5);

for (int i = 0; i < 10; i++) {
    Thread thread = new Thread(() -> {
        try {
            semaphore.acquire();
            System.out.println(Thread.currentThread().getName() + "正在执行任务。。。");
            Thread.sleep(1000);
            System.out.println(Thread.currentThread().getName() + "任务执行完毕!!!");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaphore.release();
        }
    });
    thread.start();
}
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/603185.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号