当前位置：文江博客话题详情

使用信号量来控制线程数量

发布于 2024-10-21 13:27:39 字数 38 浏览 2 评论 0原文

如何利用 Semaphore 类来控制有权访问对象的线程数量？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

阪姬 2024-10-28 13:27:40

使用允许的最大线程数初始化信号量，
如果线程进入限制区域，则将信号量计数器减一；
如果线程离开限制区域，则将信号量计数器加一

回复收藏 0 原文

清欢 2024-10-28 13:27:40

使用信号量控制对资源的访问的另一件好事是您可以在运行时调整信号量的大小。例如，您可以有一些用例，您希望允许更多用户基于某些业务逻辑访问资源，然后再次减少资源。
可调整大小信号量的示例代码

public class ResizeableSemaphore extends Semaphore
{

    private static final long serialVersionUID = 1L;
    private int permit;
    public ResizeableSemaphore(int permit) {
        super(permit);
        this.permit=permit;
    }       

    public synchronized void resizeIfRequired(int newPermit)
    {
        int delta = newPermit - permit;
        if(delta==0) return;
        if(delta > permit) this.release(delta); // this will increase capacity
        if(delta < 0) this.reducePermits(Math.abs(delta));
        this.permit=newPermit;
    }   
}

One more good thing about using semaphore to control access to resouce is you can resize your semaphore at runtime. For eg you can have some use case where you want to allow more user to access resource based on some business logic and then reduce it again.
Sample code for re sizable semaphore

public class ResizeableSemaphore extends Semaphore
{

    private static final long serialVersionUID = 1L;
    private int permit;
    public ResizeableSemaphore(int permit) {
        super(permit);
        this.permit=permit;
    }       

    public synchronized void resizeIfRequired(int newPermit)
    {
        int delta = newPermit - permit;
        if(delta==0) return;
        if(delta > permit) this.release(delta); // this will increase capacity
        if(delta < 0) this.reducePermits(Math.abs(delta));
        this.permit=newPermit;
    }   
}

回复收藏 0 原文