Semaphore 信号量

一、Semaphore 简介

1）Semaphore类其实就是synchronized关键字的升级版，这个类主要做用就是控制线程并发的数量。Semaphore能够维护当前访问自身的线程个数，而且提供了同步机制。使用Semaphore能够控制
同时访问资源的线程个数。例如，实现一个文件容许的并发访问数：如如今只容许3个并发同时读取文件，但如今有10个线程须要访问， 只有当那3个线程中任何一个访问完毕后，其余7个线程数中的其中一个才能去访问。

2）单个信号量的Semaphore对象能够实现互斥锁的功能（Semaphore sp = new Semaphore(1);），而且能够是由一个线程得到了“锁”，再由另一个线程释放“锁”，这能够应用与死锁恢复的一些场合。

3）Semaphore有两种模式，公平模式和非公平模式。公平模式就是调用acquire的顺序就是获取许可证的顺序，遵循FIFO；而非公平模式是抢占式的，也就是有可能一个新的获取线程刚好在一个许可证释放时获得了这个许可证，而前面还有等待的线程，简单的说就是随机选取新线程来运行。

二、Semaphore demo

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

/**
 * Semaphore 信号量Demo
 *
 */
public class SemaphoreTest {

	public static void main(String[] args) {
		ExecutorService service = Executors.newCachedThreadPool();
		// 建立信号量，数量为3
		final Semaphore sp = new Semaphore(3);
		// 开启10个线程
		for (int i = 0; i < 10; i++) {
			Runnable runnable = new Runnable() {
				@Override
				public void run() {
					try {
						// 得到信号量
						sp.acquire();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					System.out.println("线程" + Thread.currentThread().getName() + "当前已有" + (3 - sp.availablePermits() + "个并发"));
					try {
						// 模仿线程操做
						Thread.sleep((long) (Math.random() * 10000));
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					System.out.println("线程" + Thread.currentThread().getName() + "即将离开");
					// 释放信号
					sp.release();
					System.out.println("线程" + Thread.currentThread().getName() + "已离开，当前已有" + (3 - sp.availablePermits() + "个并发"));
				}
			};
			// 执行线程
			service.execute(runnable);
		}
	}
}

运行结果图：