日常零碎记录之Java信号量-Semaphore
日常零碎记录,即把日常学习,工作中接触到的一些知识点或者没用过的知识记录下来的一个系列。方便自己巩固,也希望能给大家一点点有意义的资料参考。
Semaphore是Java提供的的一个计数信号量,内部维护了一定数目的许可证(内部许可证的获取和释放是在AbstractQueuedSynchronizer的基础上进行的)。可以有效的控制线程的数量,避免过多线程造成的内存消耗过大。
Semaphore在创建时,通过构造器指定Semaphore的许可证数目,每次线程一次操作,都需要先调用acquire方法获取许可证许可进行下一步的操作,每次线程执行操作完毕后,再调用release方法释放持有的许可证,让其他线程能够获取并执行自己的业务操作。
总的来说,使用Semaphore时,大体有三个步骤:
1.创建Semaphore,构造器中指定许可证数量;
2.执行线程操作前,执行acquire()方法获取许可证,如果没有,将一直阻塞等等;
3.完成业务操作后,执行release()方法释放许可证,让给其他线程获取执行;
简单点,直接上个例子
import java.util.concurrent.Semaphore;
public class SemaphoreDemo {
private static Semaphore semaphore = new Semaphore(2);
public static void main(String args[]) {
SemaphoreTest();
}
public static void SemaphoreTest(){
for(int i = 0; i <= 15; i++) {
new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName()+"准备获取许可");
semaphore.acquire();
System.out.println(Thread.currentThread().getName()+"获取许可");
System.out.println("线程:"+ Thread.currentThread().getName()+" 正在执行");
Thread.sleep(400);
semaphore.release();
System.out.println(Thread.currentThread().getName()+"释放许可");
}catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
}
}
运行结果如下:
从截图可以看出,当线程0,1获取完许可证之后,其他的线程即进入了阻塞等待许可证的过程,只打印了 “****准备获取许可” 的字样,当线程0释放许可证后,其他线程也就成功获取到了许可证,随后进入了获取打印 “***正在执行” 的逻辑中去。
对于Semaphore的介绍,到这里也就结束了,下一篇,将会介绍下线程池的相关使用,然后再结合Semaphore,介绍下两者结合使用的用法及好处。