这篇文章主要讲解了“java怎么使用Semaphore实现限流器”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“java怎么使用Semaphore实现限流器”吧！
概念
Semaphore可以看作是已经被广泛地翻译成信号量，从概念上讲，信号量保持了一组凭证，获得凭证的线程可以访问资源，使用完成后释放，我们可以使用信号量来限制访问特定资源的并发线程。
可以简单概括为：一个计数器，一个等待队列，三种方法。在信号量模型中，计数器和等待队列是透明的，只能通过信号量模型提供的三种方式访问，即互联网、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实现限流器这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是编程网，小编将为大家推送更多相关知识点的文章，欢迎关注！
