java怎么使用Semaphore实现限流器

这篇文章主要讲解了“java怎么使用Semaphore实现限流器”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“java怎么使用Semaphore实现限流器”吧！

概念

1、Semaphore可以看作是已经被广泛地翻译成信号量，从概念上讲，信号量保持了一组凭证，获得凭证的线程可以访问资源，使用完成后释放，我们可以使用信号量来限制访问特定资源的并发线程。

2、可以简单概括为：一个计数器，一个等待队列，三种方法。在信号量模型中，计数器和等待队列是透明的，只能通过信号量模型提供的三种方式访问，即互联网、acquire和release。

实例

public class SemaphoreDemo {
 
    static class Link {
    }
 
    static class ObjPool<T, R> {
 
        final List<T> pool;
 
        final Semaphore semaphore;
 
        ObjPool(int size, T t) {
            pool = new Vector<>(size);
            for (int i = 0; i < size; i++) {
                pool.add(t);
            }
            semaphore = new Semaphore(size);
        }
 
        public R exec(Function<T, R> func) throws Exception {
            T t = null;
            semaphore.acquire();
            try {
                System.out.println(Thread.currentThread().getName() + "---------争夺锁--------");
 
                t = pool.remove(0);
                System.out.println(Thread.currentThread().getName() + " 拿到锁执行");
                return func.apply(t);
            } finally {
                pool.add(t);
                semaphore.release();
            }
        }
    }
 
    public static void main(String[] args) {
        ObjPool objPool = new ObjPool(5, new Link());
        for (int i = 0; i < 30; i++) {
            new Thread(() -> {
                try {
                    objPool.exec(t -> t.toString());
                } catch (Exception e) {
                }
            }).start();
        }
    }
}

感谢各位的阅读，以上就是“java怎么使用Semaphore实现限流器”的内容了，经过本文的学习后，相信大家对java怎么使用Semaphore实现限流器这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！