Java并发编程之Semaphore信号量控制

Semaphone介绍

通过 Semaphore，可以很容易控制某一个资源可被同时访问的个数。

它维护了当前访问的个数，提供同步机制来控制同时访问个数

Semaphore 对象被实例化时，需要告诉它许可的个数，线程只有获取许可，才能对资源进行访问。

Semaphore 提供了两个方法对资源的访问进行控制

• acquire()：获取一个许可，如果没有，就等待
• release()：操作完成后，释放一个许可

Semaphore实例

public class Test {
	public static void main(String[] args) {
		ExecutorService pool = Executors.newCachedThreadPool();
		final Semaphore semaphore=new Semaphore(2);
		for(int i=0;i<20;i++){
			pool.execute(new Runnable() {
				@Override
				public void run() {
					try {
						semaphore.acquire();//获取一个许可
						test();
						semaphore.release();//释放一个许可
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			});
		}
	}
	public static void test(){
		System.out.println(Thread.currentThread().getName());
		try {
			Thread.sleep(3000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}
           

上面的例子中，可以看到，输出是每两个一块进行输出的。

也就是说，对于test（）这个方法的访问，一次性只能有两个进入。

一次性获取多个许可

Semaphore允许一次性获取和释放多个许可。

semaphore.acquire(3);//获取三个许可
test();
semaphore.release(3);//释放三个许可
           

tryAcquire（）

尝试获取一个许可,如果不能获取，就直接忽略

if(semaphore.tryAcquire()){
	dosomething......
	semaphone.release();
}
           

Semaphore的使用场景

数据库的连接数是有限的，因此当多个线程对数据库发起访问请求时，可以使用Semaphore进行访问控制。