怎么在java中利用Semaphore實現一個限流器

怎么在java中利用Semaphore實現一個限流器？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

Java可以用來干什么

Java主要應用于：1. web開發；2. Android開發；3. 客戶端開發；4. 網頁開發；5. 企業級應用開發；6. Java大數據開發；7.游戲開發等。

1、概念

Semaphore可以看作是已經被廣泛地翻譯成信號量，從概念上講，信號量保持了一組憑證，獲得憑證的線程可以訪問資源，使用完成后釋放，我們可以使用信號量來限制訪問特定資源的并發線程。

可以簡單概括為：一個計數器，一個等待隊列，三種方法。在信號量模型中，計數器和等待隊列是透明的，只能通過信號量模型提供的三種方式訪問，即互聯網、acquire和release。

2、實例

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();
        }
    }
}

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。