Java并发编程之Semaphore的使用简介
简介
Semaphore是用来限制访问特定资源的并发线程的数量，相对于内置锁synchronized和重入锁ReentrantLock的互斥性来说，Semaphore可以允许多个线程同时访问共享资源。
Semaphored的使用
构造方法
Semaphore(int permits)：创建Semaphore，并指定许可证的数量。（公平策略为非公平）
Semaphore(int permits, boolean fair)：创建Semaphore，并指定许可证的数量和公平策略。
核心方法
acquire()：从Semaphore中获取一个许可证，如果获取不到则阻塞等待，直到其他线程释放了一个许可证或者当前线程被中断。
acquire(int permits)：从Semaphore中获取指定数量的许可证，如果获取不到则阻塞等待，直到其他线程释放了对应数量的许可证或者当前线程被中断。
acquireUninterruptibly()：从Semaphore中获取一个许可证，如果获取不到则阻塞等待，直到其他线程释放了一个许可证。（不响应中断）
tryAcquire()：尝试从Semaphore中获取一个许可证，获取成功则返回true，获取失败则返回false，不会进行等待。（不受公平策略的影响，许可证可用则立即获得）
tryAcquire(long timeout, TimeUnit unit)：尝试从Semaphore中获取一个许可证，获取成功则返回true，获取失败则等待指定的时间，直到等待时间结束还是没有获取到许可证则返回false。
release()：释放一个许可证。
release(int permits)：释放指定数量的许可证。
示例
总共有5个许可证，最先获取到许可证的5个线程开始执行任务，没获取到的线程进入等待状态，直到获取到许可证的线程释放许可证后，再获取许可证执行任务。
public class Demo {
public static void main(String[] args) {
//创建许可证数量为5的Semaphore
Semaphore semaphore = new Semaphore(5);
Runnable runnable = () -> {
String threadName = Thread.currentThread().getName();
try{
//获取一个许可证
semaphore.acquire();
System.out.println(threadName + "执行任务...");
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//释放一个许可证
semaphore.release();
}
};
ExecutorService executorService = Executors.newFixedThreadPool(10);
for(int i = 0; i < 10; i++){
executorService.execute(runnable);
}
executorService.shutdown();
}
}
/* 开始输出：
* pool-1-thread-1执行任务...
* pool-1-thread-5执行任务...
* pool-1-thread-6执行任务...
* pool-1-thread-7执行任务...
* pool-1-thread-3执行任务...
* 三秒后输出：
* pool-1-thread-4执行任务...
* pool-1-thread-8执行任务...
* pool-1-thread-2执行任务...
* pool-1-thread-10执行任务...
* pool-1-thread-9执行任务...
*/
使用Semaphore实现互斥
使用Semaphore实现互斥只需要将许可证数量设置为1，这样就可以保证只有一个线程能获取到许可证。
Semaphore semaphore = new Semaphore(1);
相比内置锁synchronized和重入锁ReentrantLock，使用Semaphore实现互斥有个明显的缺点：不可重入，没有释放许可证的情况下，再次调acquire方法将导致死锁。
示例：
public class Demo {
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(1);
Runnable runnable = () -> {
String threadName = Thread.currentThread().getName();
try {
//获取一个许可证
semaphore.acquire();
System.out.println(threadName + "执行任务A...");
semaphore.acquire();
System.out.println(threadName + "执行任务B...");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//释放一个许可证
semaphore.release();
}
};
new Thread(runnable).start();
}
}
/*
* 输出结果：
* Thread-0执行任务A...
*/
“执行任务B”永远不会打印，因为许可证只有一个，第二次acquire方法的调用会因为无法获取到许可证而一直阻塞。
以上就是Java并发编程之Semaphore的使用简介的详细内容，更多关于Java并发编程之Semaphore的资料请关注脚本之家其它相关文章！
相关文章
这篇文章将通过Java带大家了解网络IO模型，包括BIO,NoBlockingIO,NIO（NewIO）,AIO等做了详细得介绍，感兴趣的小伙伴可以参考阅读本文2023-05-05
Bean的装配可以理解为依赖关系注入,Bean的装配方式也就是Bean 的依赖注入方式.Spring容器支持多种形式的Bean的装配方式,如基于XML的Bean装配,基于Annotation的Bean装配和自动装配等.本文就带大家了解SpringBean基于XML的装配,需要的朋友可以参考下2021-05-05
这篇文章主要介绍了Spring Cloud构建Eureka应用的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-03-03
在Java当中synchronized关键字通常是用来标记一个方法或者代码块。本文将通过示例为大家详细介绍一下Synchronized的各种使用方法，需要的可以参考一下2022-08-08
这篇文章主要介绍了java_IO向文件中写入和读取内容，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-03-03
这篇文章主要介绍了javax NotBlank和Email注解失效的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
这篇文章主要介绍了maven+springboot打成jar包的方法,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2018-10-10
这篇文章主要介绍了Groovy的规则脚本引擎实例解读，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
本文力图通过实例加使用场合详解来引导菜鸟重新认识break和continue语句,需要的朋友可以参考下2014-01-01
这篇文章主要给大家介绍了关于Java实现快速排序算法的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-12-12
最新评论