Semaphore
是jdk中提供的用来限制资源可以同时被几个线程访问的工具类,它底层也是用aqs实现的。
以现实生活中停车场的例子来举例,一个停车场总的车位数是固定的,
@Slf4j
public class ThreadTest4 {
public static void main(String[] args) {
//假设只能停两辆车
Semaphore semaphore = new Semaphore(2);
for (int i = 0; i < 3; i++) {
Thread t = new Thread(new Runnable() {
@Override
public void run() {
try {
semaphore.acquire();//获取一个车位
log.info("停车");
Thread.sleep(5000);
semaphore.release();//离开停车场
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
t.start();
}
}
}
//控制台输出 只有前两个车中某一个车离开后第三辆车才能进入停车场
17:32:46.610 [Thread-0] INFO com.lyy.service.thread.ThreadTest4 - 停车
17:32:46.610 [Thread-1] INFO com.lyy.service.thread.ThreadTest4 - 停车
17:32:51.621 [Thread-2] INFO com.lyy.service.thread.ThreadTest4 - 停车
这就是信号量Semaphore
的一个简单使用