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

 更新时间:2019年08月04日 14:24:55   作者:大愚若智_  
这篇文章主要介绍了Java中Semaphore(信号量)的使用方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

Semaphore的作用:

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

Semaphore实现原理初探:

Semaphore是用来保护一个或者多个共享资源的访问,Semaphore内部维护了一个计数器,其值为可以访问的共享资源的个数。一个线程要访问共享资源,先获得信号量,如果信号量的计数器值大于1,意味着有共享资源可以访问,则使其计数器值减去1,再访问共享资源。

如果计数器值为0,线程进入休眠。当某个线程使用完共享资源后,释放信号量,并将信号量内部的计数器加1,之前进入休眠的线程将被唤醒并再次试图获得信号量。

就好比一个厕所管理员,站在门口,只有厕所有空位,就开门允许与空侧数量等量的人进入厕所。多个人进入厕所后,相当于N个人来分配使用N个空位。为避免多个人来同时竞争同一个侧卫,在内部仍然使用锁来控制资源的同步访问。

Semaphore的使用:

Semaphore使用时需要先构建一个参数来指定共享资源的数量,Semaphore构造完成后即是获取Semaphore、共享资源使用完毕后释放Semaphore。

Semaphore semaphore = new Semaphore(10,true);
semaphore.acquire();
//do something here
semaphore.release();

下面的代码就是模拟控制商场厕所的并发使用:

public class ResourceManage { 
  private final Semaphore semaphore ; 
  private boolean resourceArray[]; 
  private final ReentrantLock lock; 
  public ResourceManage() { 
    this.resourceArray = new boolean[10];//存放厕所状态 
    this.semaphore = new Semaphore(10,true);//控制10个共享资源的使用,使用先进先出的公平模式进行共享;公平模式的信号量,先来的先获得信号量 
    this.lock = new ReentrantLock(true);//公平模式的锁,先来的先选 
    for(int i=0 ;i<10; i++){ 
      resourceArray[i] = true;//初始化为资源可用的情况 
    } 
  } 
  public void useResource(int userId){ 
 semaphore.acquire(); 
    try{ 
      //semaphore.acquire(); 
      int id = getResourceId();//占到一个坑 
      System.out.print("userId:"+userId+"正在使用资源,资源id:"+id+"\n"); 
      Thread.sleep(100);//do something,相当于于使用资源 
      resourceArray[id] = true;//退出这个坑 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    }finally { 
      semaphore.release();//释放信号量,计数器加1 
    } 
  } 
  private int getResourceId(){ 
    int id = -1; 
 lock.lock();
    try { 
      //lock.lock();//虽然使用了锁控制同步,但由于只是简单的一个数组遍历,效率还是很高的,所以基本不影响性能。 
      for(int i=0; i<10; i++){ 
        if(resourceArray[i]){ 
          resourceArray[i] = false; 
          id = i; 
          break; 
        } 
      } 
    }catch (Exception e){ 
      e.printStackTrace(); 
    }finally { 
      lock.unlock(); 
    } 
    return id; 
  } 
} 
public class ResourceUser implements Runnable{ 
  private ResourceManage resourceManage; 
  private int userId; 
  public ResourceUser(ResourceManage resourceManage, int userId) { 
    this.resourceManage = resourceManage; 
    this.userId = userId; 
  } 
  public void run(){ 
    System.out.print("userId:"+userId+"准备使用资源...\n"); 
    resourceManage.useResource(userId); 
    System.out.print("userId:"+userId+"使用资源完毕...\n"); 
  } 
 
  public static void main(String[] args){ 
    ResourceManage resourceManage = new ResourceManage(); 
    Thread[] threads = new Thread[100]; 
    for (int i = 0; i < 100; i++) { 
      Thread thread = new Thread(new ResourceUser(resourceManage,i));//创建多个资源使用者 
      threads[i] = thread; 
    } 
    for(int i = 0; i < 100; i++){ 
      Thread thread = threads[i]; 
      try { 
        thread.start();//启动线程 
      }catch (Exception e){ 
        e.printStackTrace(); 
      } 
    } 
  } 
}

最后,Semaphore除了控制资源的多个副本的并发访问控制,也可以使用二进制信号量来实现类似synchronized关键字和Lock锁的并发访问控制功能。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Java读取json数据并存入数据库的操作代码

    Java读取json数据并存入数据库的操作代码

    很多朋友问大佬们JAVA怎么把json存入数据库啊,这一问题就把我难倒了,纠结如何操作呢,下面小编把我的经验分享给大家,感兴趣的朋友一起看看吧
    2021-08-08
  • Java用jxl读取excel并保存到数据库的方法

    Java用jxl读取excel并保存到数据库的方法

    这篇文章主要为大家详细介绍了Java用jxl读取excel并保存到数据库的方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-10-10
  • SpringBoot中Jackson日期格式化技巧分享

    SpringBoot中Jackson日期格式化技巧分享

    一般在SpringBoot项目中,spring默认使用jackson转换日期,下面这篇文章主要给大家介绍了关于SpringBoot中Jackson日期格式化技巧的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
    2022-04-04
  • Java平闰年判断的方法总结

    Java平闰年判断的方法总结

    本篇文章给大家整理了Java平闰年判断的两种方法,大家在写程序的时候如果用的到参考下吧。
    2018-02-02
  • 在SpringBoot微服务中设置和管理多个数据库的代码示例

    在SpringBoot微服务中设置和管理多个数据库的代码示例

    在现代微服务架构中,通常需要与多个数据库交互的服务,这可能是由于各种原因,例如遗留系统集成、不同类型的数据存储需求,或者仅仅是为了优化性能,在本综合指南中,我们将探讨如何在 Spring Boot 微服务中设置和管理多个数据库连接,需要的朋友可以参考下
    2024-12-12
  • SpringBoot项目如何设置权限拦截器和过滤器

    SpringBoot项目如何设置权限拦截器和过滤器

    这篇文章主要介绍了使用lombok时如何自定义get、set方法问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • Java 实现多线程的几种方式汇总

    Java 实现多线程的几种方式汇总

    JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没有返回值,只有最后一种是带返回值的。
    2016-03-03
  • Java中异常Exception和捕获以及自定义异常详解

    Java中异常Exception和捕获以及自定义异常详解

    在工作过程中,我们常常需要在合适的地方抛出合适的异常,除了java自带的一些异常,我们可以在项目中定制自己的异常,并且全局捕获它,下面这篇文章主要给大家介绍了关于Java中异常Exception和捕获以及自定义异常的相关资料,需要的朋友可以参考下
    2023-05-05
  • SpringBoot的@Value注解如何设置默认值

    SpringBoot的@Value注解如何设置默认值

    这篇文章主要介绍了SpringBoot的@Value注解如何设置默认值问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-02-02
  • Java事务管理学习之JDBC详解

    Java事务管理学习之JDBC详解

    这篇文章主要介绍了Java事务管理学习之JDBC的相关资料,文中介绍的非常详细,相信对大家具有一定的参考价值,需要的朋友们下面来一起看看吧。
    2017-03-03

最新评论