526互联

信号量Semaphore的使用

发布时间 2023-10-29 17:45:26作者: 程序晓猿

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 的一个简单使用