Semaphore(信号量)的使用

作者: 奔跑吧李博 | 来源:发表于2022-12-27 15:54 被阅读0次

信号量,是一种共享锁,多个线程同时访问一个资源时,通过它实现同一时刻的访问线程数量。最常见的使用场景就是高并发下的限流。

Semaphore常用方法说明

acquire()  
获取一个令牌,在获取到令牌、或者被其他线程调用中断之前线程一直处于阻塞状态。

tryAcquire()
尝试获得令牌,返回获取令牌成功或失败,不阻塞线程。

availablePermits()
返回可用的令牌数量。

release()
释放一个令牌,唤醒一个获取令牌不成功的阻塞线程。
示例:

每个停车场入口都有一个提示牌,上面显示着停车场的剩余车位还有多少,当剩余车位为0时,不允许车辆进入停车场,直到停车场里面有车离开停车场,这时提示牌上会显示新的剩余车位数。

1、停车场容纳总停车量10。
2、当一辆车进入停车场后,显示牌的剩余车位数响应的减1.
3、每有一辆车驶出停车场后,显示牌的剩余车位数响应的加1。
4、停车场剩余车位不足时,车辆只能在外面等待。

代码:
public class SemaphoreUtil {
    private static Semaphore semaphore = new Semaphore(10);

    public static void main(String[] args) {
        for (int i=0;i<50;i++) {
            Thread thread = new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + "到停车场门口");
                    if (semaphore.availablePermits() == 0) {
                        System.out.println("车位已满");
                    }
                    //车位未满,可以获取进入权限
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "进入了停车场");
                    Thread.sleep(new Random().nextInt(10000));//模拟车辆在停车场停留的时间
                    System.out.println(Thread.currentThread().getName()+"驶出停车场");
                    semaphore.release(); //释放令牌,更新空车位
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            thread.start();
        }
    }
}

相关文章

网友评论

    本文标题:Semaphore(信号量)的使用

    本文链接:https://www.haomeiwen.com/subject/yepnqdtx.html