1. Semaphore 是什么?
Semaphore 字面意思是信号量的意思,它的作用是控制访问特定资源的线程数目。
2. 怎么使用 Semaphore?
2.1 构造方法
public Semaphore(int permits)
public Semaphore(int permits, boolean fair)
解析:
- permits 表示许可线程的数量
- fair 表示公平性,如果这个设为 true 的话,下次执行的线程会是等待最久的线程
2.2 重要方法
public void acquire() throws InterruptedException
public void release()
解析:
- acquire() 表示阻塞并获取许可
- release() 表示释放许可
2.3 基本使用
2.3.1 需求
多个线程同时执行,但是限制同时执行的线程数量为 2 个。
2.3.2 代码实现
public class SemaphoreDemo {
static class TaskThread extends Thread {
Semaphore semaphore;
public TaskThread(Semaphore semaphore) {
this.semaphore = semaphore;
}
@Override
public void run() {
try {
semaphore.acquire();
System.out.println(getName() + " acquire");
Thread.sleep(1000);
semaphore.release();
System.out.println(getName() + " release ");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
int threadNum = 5;
Semaphore semaphore = new Semaphore(2);
for (int i = 0; i < threadNum; i++) {
new TaskThread(semaphore).start();
}
}
}
打印结果:
Thread-1 acquire
Thread-0 acquire
Thread-0 release
Thread-1 release
Thread-2 acquire
Thread-3 acquire
Thread-2 release
Thread-4 acquire
Thread-3 release
Thread-4 release
从打印结果可以看出,一次只有两个线程执行 acquire(),只有线程进行 release() 方法后才会有别的线程执行 acquire()。
需要注意的是 Semaphore 只是对资源并发访问的线程数进行监控,并不会保证线程安全。
3. Semaphore 使用场景
可用于流量控制,限制最大的并发访问数。
网友评论