Java并发编程信号量Semapher
更新时间：2022年04月15日 16:24:59 作者：派大大大星
这篇文章主要介绍了Java并发编程信号量Semapher，Semapher信号量也是Java中的一个同步器，下文关于信号量Semapher的更多内容介绍，需要的小伙伴可以参考下面文章
Semapher信号量也是Java中的一个同步器，与CountDownLatch和CycleBarrier不同的是，它内部的计数器是递增的，并且在一开始初始化Semaphoer时可以指定一个初始值，但是并不需要知道需要同步的线程个数，而是在需要同步的地方调用acquire方法时指定需要同步的线程个数。
我们通过下面一个例子来看一下Semapher效果：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class SemaphoreTest {
private static Semaphore semaphore = new Semaphore(0);
public static void main(String[] args) throws InterruptedException{
ExecutorService executorService = Executors.newFixedThreadPool(2);
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
semaphore.acquire(2);
System.out.println("all child thread over!");
executorService.shutdown();
}
}
如上代码首先创建了一个信号量实例，构造函数的入参为0，说明当前信号量计数器的值为0。然后，main函数向线程池添加两个线程任务，在每个线程内部调用信号量的acquire方法，传参为2说明调用acquire方法的线程会一直阻塞，知道信号量的技术变为2才会返回。如果构造Semaphore时，传递的参数为N，并在M个线程中调用了该信号量的release方法，那么在调用acquire使M个线程同步时传递的参数应该是M+N。
下面举例子来模拟CycliBarrier复用的功能，代码如下：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class Semaphoer {
private static Semaphore semaphore = new Semaphore(0);
public static void main(String[] args) throws InterruptedException {
ExecutorService executorService = Executors.newFixedThreadPool(2);
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "A task over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "A task over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
semaphore.acquire(2);
System.out.println("task A is over");
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "B task over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
executorService.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread() + "B task over");
semaphore.release();
} catch (Exception e) {
e.printStackTrace();
}
}
});
semaphore.acquire(2);
System.out.println("task B is over");
executorService.shutdown();
}
}
如上代码首先将线程A和线程B加入到线程池。主线程执行代码(1)后被阻塞。线程A和线程B调用release方法后信号量的值变为了2，这时候主线程的aquire方法会在获取到2个信号量后返回(返回后当前信号量值为0)。然后主线程添加线程C和线程D到线程池，之后主线程执行代码(2)后被阻塞(因为主线程要获取2个信号量，而当前信号量个数为0)。当线程C和线程D执行完release 方法后，主线程才返回。从本例子可以看出，Semaphore 在某种程度上实现了CyclicBarrier 的复用功能。
到此这篇关于Java并发编程信号量Semapher的文章就介绍到这了,更多相关Java Semapher内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了最常用的1000个Java类（附代码示例）,需要的朋友可以参考下2015-04-04
这篇文章主要介绍了SpringMVC整合,出现注解没有起作用的情况及处理，具有很好的参考价值，希望对大家有所帮助。2023-05-05
这篇文章主要为大家详细介绍了java实现多人聊天系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-09-09
这篇文章主要介绍了Java递归调用如何实现数字的逆序输出方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-04-04
这篇文章主要介绍了Android Home 键监听的实现代码,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-12-12
这篇文章主要介绍了Java性能优化技巧,汇总了提升java程序性能的常用技巧,非常具有实用价值,需要的朋友可以参考下2015-04-04
这篇文章主要介绍了匿名内部类、多线程、如何实现同步、序列化，这四个难理解的概念，同学们一定要仔细看看2021-04-04
这篇文章主要介绍了 Java数据结构的十大排序，排序算法分为比较类排序和非比较类排序，具体的内容，需要的朋友参考下面思维导图及文章介绍，希望对你有所帮助2022-01-01
这篇文章主要介绍了Spring Security用户定义，大家都知道 Spring Security的用户定义有很多方式，其实主要有两种，基于内存的和基于数据库的，下面我给大家简单介绍一下这两种方式,需要的朋友可以参考下2022-02-02
SpringBoot自带Tomcat，直接运行main方法里面的SpringApplication.run即可，并且访问时不需要带项目名，这篇文章主要介绍了Idea启动多个SpringBoot项目的3种方案,需要的朋友可以参考下2023-02-02
最新评论