如上代码首先创建了一个信号量实例，构造函数的入参为0，说明当前信号量计数器的值为0。然后，main函数向线程池添加两个线程任务，在每个线程内部调用信号量的acquire方法，传参为2说明调用acquire方法的线程会一直阻塞，知道信号量的技术变为2才会返回。如果构造Semaphore时，传递的参数为N，并在M个线程中调用了该信号量的release方法，那么在调用acquire使M个线程同步时传递的参数应该是M+N。
下面举例子来模拟CycliBarrier复用的功能，代码如下：
如上代码首先将线程A和线程B加入到线程池。主线程执行代码(1)后被阻塞。线程A和线程B调用release方法后信号量的值变为了2，这时候主线程的aquire方法会在获取到2个信号量后返回(返回后当前信号量值为0)。然后主线程添加线程C和线程D到线程池，之后主线程执行代码(2)后被阻塞(因为主线程要获取2个信号量，而当前信号量个数为0)。当线程C和线程D执行完release 方法后，主线程才返回。从本例子可以看出，Semaphore 在某种程度上实现了CyclicBarrier 的复用功能。
到此这篇关于Java并发编程信号量Semapher的文章就介绍到这了,更多相关Java Semapher内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记！
