原文連結 作者：Dimitris Andreou  譯者：魏嘉鵬 校對：方騰飛

RateLimiter 從概念上來講，速率限制器會在可配置的速率下分配許可證。如果必要的話，每個acquire() 會阻塞當前執行緒直到許可證可用後獲取該許可證。一旦獲取到許可證，不需要再釋放許可證。

校對注：RateLimiter使用的是一種叫令牌桶的流控演算法，RateLimiter會按照一定的頻率往桶裡扔令牌，執行緒拿到令牌才能執行，比如你希望自己的應用程式QPS不要超過1000，那麼RateLimiter設定1000的速率後，就會每秒往桶裡扔1000個令牌。

com.google.common.util.concurrent.RateLimiter

@ThreadSafe
@Betapublic
abstract class RateLimiter extends Object

RateLimiter經常用於限制對一些物理資源或者邏輯資源的訪問速率。與Semaphore 相比，Semaphore 限制了併發訪問的數量而不是使用速率。（注意儘管併發性和速率是緊密相關的，比如參考Little定律）

通過設定許可證的速率來定義RateLimiter。在預設配置下，許可證會在固定的速率下被分配，速率單位是每秒多少個許可證。為了確保維護配置的速率，許可會被平穩地分配，許可之間的延遲會做調整。
可能存在配置一個擁有預熱期的RateLimiter 的情況，在這段時間內，每秒分配的許可數會穩定地增長直到達到穩定的速率。

舉例來說明如何使用RateLimiter，想象下我們需要處理一個任務列表，但我們不希望每秒的任務提交超過兩個：

//速率是每秒兩個許可
final RateLimiter rateLimiter = RateLimiter.create(2.0);

void submitTasks(List tasks, Executor executor) {
    for (Runnable task : tasks) {
        rateLimiter.acquire(); // 也許需要等待
        executor.execute(task);
    }
}

再舉另外一個例子，想象下我們製造了一個數據流，並希望以每秒5kb的速率處理它。可以通過要求每個位元組代表一個許可，然後指定每秒5000個許可來完成：

// 每秒5000個許可
final RateLimiter rateLimiter = RateLimiter.create(5000.0); 

void submitPacket(byte[] packet) {
    rateLimiter.acquire(packet.length);
    networkService.send(packet);
}

有一點很重要，那就是請求的許可數從來不會影響到請求本身的限制（呼叫acquire(1) 和呼叫acquire(1000) 將得到相同的限制效果，如果存在這樣的呼叫的話），但會影響下一次請求的限制，也就是說，如果一個高開銷的任務抵達一個空閒的RateLimiter，它會被馬上許可，但是下一個請求會經歷額外的限制，從而來償付高開銷任務。注意：RateLimiter 並不提供公平性的保證。

Since:13.0  作者:   Dimitris Andreou

方法摘要

方法細節