Java并发系列3

考虑这样的场景：我司出了一款新游戏，因模式新颖、宣传到位，导致游戏开服火爆，每次新开一个服务器就会一下涌入大量玩家。假如一个线路服务器的承载力上限是5000，那么我们该通过什么机制进行资源调配呢？
比较容易想到的方法就是给每个玩家发许可证，同时一个服务器的许可证上限为5000，这样的话，许可证超出上限则玩家需要排队。
今天我们讲的并发工具就如同代码层面的许可证。
先来看代码：

1public class SemapDemo implements Runnable {
2	final Semaphore semaphore = new Semaphore(5);
3
4	@Override
5	public void run() {
6		try {
7			semaphore.acquire();
8			Thread.sleep(1000);
9			System.out.println(Thread.currentThread().getId() + "done!");
10			semaphore.release();
11		} catch (InterruptedException e) {
12			e.printStackTrace();
13		}
14
15	}
16
17	public static void main(String[] args) {
18		ExecutorService service = Executors.newFixedThreadPool(20);
19		SemapDemo demo = new SemapDemo();
20		for (int i = 0; i < 20; i++) {
21			service.execute(demo);
22		}
23		service.shutdown();
24	}
25}

看到我们的主角：Semaphore，他的构造必须有一个参数，表示许可证的数量。
Semaphore的主要方法有：

• acquire() 用于获取一个许可，如果暂时无法获得，则进行等待
• acquireUninterruptibly() 不响应中断的acquire()方法
• tryAcquire() 尝试获得一个许可，成功返回true；不成功立即返回。还有一个可设置等待时间的重载方法
• release() 释放一个许可

我们看到这个工具类使用起来还是相对简单的。
扩展阅读：锁框架核心：AbstractQueuedSynchronizer