Java多线程Semaphore

Semaphore为并发包中提供用于控制某资源同时可以被几个线程访问的类

实例代码:

// 允许2个线程同时访问
final Semaphore semaphore = new Semaphore(2);
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
	final int index = i; 
	executorService.execute(new Runnable() {
		public void run() {
			try {
				semaphore.acquire();
				// 这里可能是业务代码
				System.out.println("线程:" + Thread.currentThread().getName() + "获得许可:" + index);
				TimeUnit.SECONDS.sleep(1);
				semaphore.release();
				System.out.println("允许TASK个数:" + semaphore.availablePermits());  
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	});
}
executorService.shutdown();

构造方法1:

public Semaphore(int permits) {
    sync = new NonfairSync(permits);
}

permits 初始许可数,也就是最大访问线程数

构造方法2:

public Semaphore(int permits, boolean fair) {  
    sync = (fair)? new FairSync(permits) : new NonfairSync(permits);  
}

permits 初始许可数,也就是最大访问线程数

fair 当设置为false时,线程获取许可的顺序是无序的,也就是说新线程可能会比等待的老线程会先获得许可;当设置为true时,信号量保证它们调用的顺序(即先进先出;FIFO)

主要方法:

void  acquire():从信号量获取一个许可,如果无可用许可前 将一直阻塞等待,

void acquire(int permits):获取指定数目的许可,如果无可用许可前  也将会一直阻塞等待

This chapter requires login to view full content. You are viewing a preview.

Login to View Full Content

Course Curriculum

3

框架与 I/O:Spring、Netty 与 Web 容器

理解 Spring Boot 自动装配、AOP 与事务原理,掌握 Netty Reactor 模型及 Tomcat 连接处理机制,构建高内聚、易扩展的应用服务层。
4

高性能中间件:消息、缓存与存储

熟练运用 MySQL 索引/事务、Redis 缓存策略、Kafka/RocketMQ 消息可靠性,以及 ZooKeeper 分布式协调,搭建稳定、解耦的分布式数据底座。
6

云原生:容器化、可观测性与工程效能

通过 Docker/K8s 实现弹性部署,集成 Metrics/Logs/Traces 构建可观测体系,推动 DevOps 与自动化,让架构在云上持续交付与进化。