Java中的Semaphore如何使用

目录
  • 简介
  • 简述实现原理
  • 方法介绍
  • 案例分析
  • 适用场景

简介

semaphore中文意思既是信号量,它的主要功能就是用来控制某个资源同时被访问的线程数。

为了控制某块资源的并发访问量时,可以使用Semaphore对象中的acquire()方法获取访问令牌,如果Semaphore对象访问令牌已发完,那么当前获取令牌的线程将会进入阻塞,带其他线程进行release()释放令牌时,当前线程才有机会获得令牌从而拥有访问权限。

简述实现原理

Semaphore实际上是一种共享锁,因为它允许多个线程并发获取共享的资源。在Semaphore对象创建时必须设置可用令牌的初始数量permits,用于控制并发时同时获取资源权限的线程数量。在Semaphore类中继承了同步队列AbstractQueuedSynchronizer,在此类中有个属性state用于标记当前并发的队列数,也就是获取令牌的线程数,那么在进行acquire()的时候,就会尝试获取共享锁,获取锁成功后state值将加1,如果state值已经达到permits时就表示令牌已派发完,当前线程将进入阻塞状态,待其他线程进行release()state值将减1,此时就会从队列中获取头部线程进行唤醒让其获得令牌进行资源访问。

如下图,仔细查看源码就会发现Semaphore实际上就是重写了AbstractQueuedSynchronizer中的tryAcquireShared()tryReleaseShared()方法来实现的。

方法介绍

  • Semaphore重载了两个构造函数,其一是Semaphore(int permits)直接指定令牌数,默认为非公平锁;其二是Semaphore(int permits,boolean fair),fair参数即表示线程抢占令牌的公平性,true为公平锁,否则为非公平锁。
  • acquire()无参表示默认获取一个令牌,acquire(int permits)表示获取指定permits数量的令牌数,如果令牌不够,则当前线程进入阻塞状态。

tryAcquire()无参表示尝试获取一个令牌,该方法是非阻塞的,所以如果令牌数不够获取失败返回false,否则就返回true;同时也重载了方法tryAcquire(int permits)指定获取令牌数,tryAcquire(int permits, long timeout, TimeUnit unit)在有效时间内尝试获取指定数量的令牌数,如果超时仍未获取到令牌则返回false,否则返回true。 release同上支持无参与带参指定释放令牌数的方法。 drainPermits()获取剩下的可用令牌。 hasQueuedThread()用于判断当前Semaphare实例中是否存在等待获取令牌的线程。

案例分析

分析一下下面这段简短的代码,首先是创建一个信号量为5的Semaphore对象,然后在创建一个线程池(这里为了演示方便,实际开发中不建议使用此线程池创建),利用for循环并发运行100个线程,当线程运行时优先获取一个令牌,在线程中的业务代码里我们做了1秒的休眠,为了展示等待获取令牌的效果,在延迟1秒执行完业务代码时进行令牌释放,后续的线程才能逐个被唤醒获取令牌访问共享资源。

@Slf4j
public class SemaphoreDemo {

    public static void main(String[] args) {
        Semaphore semaphore = new Semaphore(5);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 100; i++) {
            executorService.execute(() -> {
                try {
                    semaphore.acquire();
                    log.info("成功获取令牌");
                    TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    log.info("释放令牌");
                    semaphore.release();
                }
            });
        }
        executorService.shutdown();
    }
}
  • 运行结果

由下图运行结果可见,100个线程并发并不是一次性都执行完的,而是要等待前面的线程释放令牌后等待的线程才可以获取令牌进行业务代码的运行。

适用场景

Semaphore主要是运用在多线程环境中对某一些共享资源的访问量限制,防止多个线程并发访问同一资源,可能会导致大多数线程获取资源时都需要进行加锁,那如果是获取数据库中的数据,那么就可以缓解数据库的压力。

另一种情况是用于多线程运行的一个流量限制,一般情况下我们可能会通过线程池做一步线程数的控制,但是某些业务为了减轻CPU的负担,还是会做一些同时运行线程数的限制。

到此这篇关于Java中的Semaphore如何使用的文章就介绍到这了,更多相关Semaphore使用内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Java并发编程之工具类Semaphore的使用

    一.Semaphore的理解 Semaphore属于java.util.concurrent包: Semaphore翻译成字面意思为信号量,Semaphore可以控制同时访问的线程个数,通过acquire()获取一个许可,如果没有就等待,而release()释放一个许可. 二.Semaphore类中常用方法 public void acquire() 用来获取一个许可,若无许可能够获得,则会一直等待,直到获得许可. public void acquire(int permits) 获取permi

  • Java中Semaphore(信号量)的使用方法

    Semaphore的作用: 在java中,使用了synchronized关键字和Lock锁实现了资源的并发访问控制,在同一时间只允许唯一了线程进入临界区访问资源(读锁除外),这样子控制的主要目的是为了解决多个线程并发同一资源造成的数据不一致的问题.在另外一种场景下,一个资源有多个副本可供同时使用,比如打印机房有多个打印机.厕所有多个坑可供同时使用,这种情况下,Java提供了另外的并发访问控制--资源的多副本的并发访问控制,今天学习的信号量Semaphore即是其中的一种. Semaphore实现

  • Java使用Semaphore对单接口进行限流

    目录 一.实战说明 1.1 效果说明 1.2 核心知识点 二. 环境搭建 三.限流演示 3.1 并发请求工具 3.2 效果示例图 一.实战说明 1.1 效果说明 本篇主要讲如何使用Semaphore对单接口进行限流,例如有如下场景 a. A系统的有a接口主要给B系统调用,现在希望对B系统进行限流,例如处理峰值在100,超过100的请求快速失败 b. 接口作为总闸入口,希望限制所有外来访问,例如某个房间只能同时100个玩家在线,只有前面的处理完后面的才能继续请求 c. 其他类型场景,也就是资源固定

  • Java并发编程之Semaphore的使用简介

    简介 Semaphore是用来限制访问特定资源的并发线程的数量,相对于内置锁synchronized和重入锁ReentrantLock的互斥性来说,Semaphore可以允许多个线程同时访问共享资源. Semaphored的使用 构造方法 Semaphore(int permits):创建Semaphore,并指定许可证的数量.(公平策略为非公平) Semaphore(int permits, boolean fair):创建Semaphore,并指定许可证的数量和公平策略. 核心方法 acqu

  • 详解Java信号量Semaphore的原理及使用

    目录 1.Semaphore的概述 2.Semaphore的原理 2.1 基本结构 2.2 可中断获取信号量 2.3 不可中断获取信号量 2.4 超时可中断获取信号量 2.5 尝试获取信号量 2.6 释放信号量 3.Semaphore的使用 4.Semaphore的总结 1.Semaphore的概述 public class Semaphore extends Object implements Serializable Semaphore来自于JDK1.5的JUC包,直译过来就是信号量,被作为

  • Java中的Semaphore如何使用

    目录 简介 简述实现原理 方法介绍 案例分析 适用场景 简介 semaphore中文意思既是信号量,它的主要功能就是用来控制某个资源同时被访问的线程数. 为了控制某块资源的并发访问量时,可以使用Semaphore对象中的acquire()方法获取访问令牌,如果Semaphore对象访问令牌已发完,那么当前获取令牌的线程将会进入阻塞,带其他线程进行release()释放令牌时,当前线程才有机会获得令牌从而拥有访问权限. 简述实现原理 Semaphore实际上是一种共享锁,因为它允许多个线程并发获取

  • Java并发编程Semaphore计数信号量详解

    Semaphore 是一个计数信号量,它的本质是一个共享锁.信号量维护了一个信号量许可集.线程可以通过调用acquire()来获取信号量的许可:当信号量中有可用的许可时,线程能获取该许可:否则线程必须等待,直到有可用的许可为止. 线程可以通过release()来释放它所持有的信号量许可(用完信号量之后必须释放,不然其他线程可能会无法获取信号量). 简单示例: package me.socketthread; import java.util.concurrent.ExecutorService;

  • 详解java中的互斥锁信号量和多线程等待机制

    互斥锁和信号量都是操作系统中为并发编程设计基本概念,互斥锁和信号量的概念上的不同在于,对于同一个资源,互斥锁只有0和1 的概念,而信号量不止于此.也就是说,信号量可以使资源同时被多个线程访问,而互斥锁同时只能被一个线程访问 互斥锁在java中的实现就是 ReetranLock , 在访问一个同步资源时,它的对象需要通过方法 tryLock() 获得这个锁,如果失败,返回 false,成功返回true.根据返回的信息来判断是否要访问这个被同步的资源.看下面的例子 public class Reen

  • Java中同步与并发用法分析

    本文较为详细的分析了Java中同步与并发的用法.分享给大家供大家参考.具体分析如下: 1.同步容器类包括两部分:vector和hashtable 另一类是同步包装类,由Collections.synchronizedXXX创建.同步容器对容器的所有状态进行串行访问,从而实现线程安全. 它们存在如下问题: a) 对于符合操作,需要额外的锁保护.比如迭代,缺少则添加等条件运算. b) toString,hashCode,equals都会间接的调用迭代,都需要注意并发.   2.java5.0中的并发

  • Java中CountDownLatch进行多线程同步详解及实例代码

    Java中CountDownLatch进行多线程同步详解 CountDownLatch介绍 在前面的Java学习笔记中,总结了Java中进行多线程同步的几个方法: 1.synchronized关键字进行同步. 2.Lock锁接口及其实现类ReentrantLock.ReadWriteLock锁实现同步. 3.信号量Semaphore实现同步. 其中,synchronized关键字和Lock锁解决的是多个线程对同一资源的并发访问问题.信号量Semaphore解决的是多副本资源的共享访问问题. 今天

  • java中变量和常量详解

    变量和常量 在程序中存在大量的数据来代表程序的状态,其中有些数据在程序的运行过程中值会发生改变,有些数据在程序运行过程中值不能发生改变,这些数据在程序中分别被叫做变量和常量. 在实际的程序中,可以根据数据在程序运行中是否发生改变,来选择应该是使用变量代表还是常量代表. 变量 变量代表程序的状态.程序通过改变变量的值来改变整个程序的状态,或者说得更大一些,也就是实现程序的功能逻辑. 为了方便的引用变量的值,在程序中需要为变量设定一个名称,这就是变量名.例如在2D游戏程序中,需要代表人物的位置,则需

  • 详解Java中的线程池

    1.简介 使用线程池可以避免线程的频繁创建以及销毁. JAVA中提供的用于实现线程池的API: Executor.ExecutorService.AbstractExecutorService.ThreadPoolExecutor.ForkJoinPool都位于java.util.concurrent包下. *ThreadPoolExecutor.ForkJoinPool为线程池的实现类. 2.Executor public interface Executor { /** * 向线程池提交一个

  • Java中synchronized实现原理详解

    记得刚刚开始学习Java的时候,一遇到多线程情况就是synchronized,相对于当时的我们来说synchronized是这么的神奇而又强大,那个时候我们赋予它一个名字"同步",也成为了我们解决多线程情况的百试不爽的良药.但是,随着我们学习的进行我们知道synchronized是一个重量级锁,相对于Lock,它会显得那么笨重,以至于我们认为它不是那么的高效而慢慢摒弃它. 诚然,随着Javs SE 1.6对synchronized进行的各种优化后,synchronized并不会显得那么

  • Java中有界队列的饱和策略(reject policy)原理解析

    我们在使用ExecutorService的时候知道,在ExecutorService中有个一个Queue来保存提交的任务,通过不同的构造函数,我们可以创建无界的队列(ExecutorService.newCachedThreadPool)和有界的队列(ExecutorService newFixedThreadPool(int nThreads)). 无界队列很好理解,我们可以无限制的向ExecutorService提交任务.那么对于有界队列来说,如果队列满了该怎么处理呢? 今天我们要介绍一下j

随机推荐