1、引入信号量（Semaphore）
信号量为多线程提供更为强大的控制方法。广义上说，信号量是对锁的扩展。无论是内部锁synchronized还是重入锁ReentrantLock，一次都只允许一个线程访问一个资源，而信号量可以指定多个线程，同时访问某一个资源。
信号量主要提供了以下构造函数：
public Semaphore(int permits)
public Semaphore(int permits, boolean fair)
在构造信号量对象时，，必须指定信号量的准入数，即同时能申请多少个许可。当每个线程每次只申请一个许可时，这就相当于制定了同时有多少个线程可以访问某一资源。
2、信号量的主要逻辑方法
public void acquire()
public void acquireUninterruptibly()
public boolean tryAcquire()
public boolean tryAcquire(long timeout, TimeUnit unit)
public void release()
- acquire()方法尝试获得一个准入的许可。若无法获得，则线程会等待，直到有线程释放一个许可或当前线程被中断。
- acquireUninterruptibly()方法和acquire()类似，但不响应中断。
- tryAcquire()尝试获得一个许可，如果成功返回true，失败则返回false，它不会进行等待，立即返回。
- tryAcquire(long timeout, TimeUnit unit)尝试在指定的时间内获得一个许可。
- release()方法用于在线程访问资源结束后，释放一个许可。以使其他等待许可的线程可以进行资源访问。
3、简单演示一下Semaphore功能
演示代码如下：
public class SemaphoreDemo implements Runnable
{
//声明了一个包含五个许可的信号量。这就意味着同时可以有5个线程进入临界区
final Semaphore semaphore = new Semaphore(5);
@Override
public void run()
{
try
{
semaphore.acquire();
//模拟耗时操作
Thread.sleep(2000);
System.out.println(Thread.currentThread().getId() + ":done!");
semaphore.release();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
public static void main(String[] args)
{
ExecutorService exec = Executors.newFixedThreadPool(20);
final SemaphoreDemo demo = new SemaphoreDemo();
for (int i = 0; i < 20; ++i)
{
exec.submit(demo);
}
}
}
上述代码中,下面代码块为临界区管理代码，程序会限制执行这段代码的线程数。申明了一个包含5个许可的信号量，这就意味着同时可以有5个线程进入下面临界区代码段。申请信号量使用acquire()操作，在离开时，务必使用release()释放信号量，这就和释放锁一个道理。如果不幸发生了信号量泄露（申请了但没释放），那么可以进入临界区的线程数就会越来越少，直到所有的线程均不可访问。在本例中，同时开启了20个线程。观察这段程序的输出，会发现系统以5个线程为一组，依次输出带有线程ID的文本。
//模拟耗时操作
Thread.sleep(2000);
System.out.println(Thread.currentThread().getId() + ":done!");
