Java并发系列3--信号量Semaphore

原创
2018/06/12 11:39
阅读数 141

考虑这样的场景:我司出了一款新游戏,因模式新颖、宣传到位,导致游戏开服火爆,每次新开一个服务器就会一下涌入大量玩家。假如一个线路服务器的承载力上限是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

展开阅读全文
0
5 收藏
分享
加载中
更多评论
打赏
0 评论
5 收藏
0
分享
返回顶部
顶部