考虑这样的场景:我司出了一款新游戏,因模式新颖、宣传到位,导致游戏开服火爆,每次新开一个服务器就会一下涌入大量玩家。假如一个线路服务器的承载力上限是5000,那么我们该通过什么机制进行资源调配呢?
比较容易想到的方法就是给每个玩家发许可证,同时一个服务器的许可证上限为5000,这样的话,许可证超出上限则玩家需要排队。
今天我们讲的并发工具就如同代码层面的许可证。
先来看代码:
public class SemapDemo implements Runnable {
final Semaphore semaphore = new Semaphore(5);
@Override
public void run() {
try {
semaphore.acquire();
Thread.sleep(1000);
System.out.println(Thread.currentThread().getId() + "done!");
semaphore.release();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(20);
SemapDemo demo = new SemapDemo();
for (int i = 0; i < 20; i++) {
service.execute(demo);
}
service.shutdown();
}
}
看到我们的主角:Semaphore,他的构造必须有一个参数,表示许可证的数量。
Semaphore的主要方法有:
- acquire() 用于获取一个许可,如果暂时无法获得,则进行等待
- acquireUninterruptibly() 不响应中断的acquire()方法
- tryAcquire() 尝试获得一个许可,成功返回true;不成功立即返回。还有一个可设置等待时间的重载方法
- release() 释放一个许可
我们看到这个工具类使用起来还是相对简单的。
扩展阅读:锁框架核心:AbstractQueuedSynchronizer