限制方法使用Guava RateLimiter类调用

Question

我试图限制每秒调用一个方法的次数.我尝试使用Guava RateLimiter实现这一目标.

RateLimiter rateLimiter = RateLimiter.create(1.0);//Max 1 call per sec
rateLimiter.acquire();
performOperation();//The method whose calls are to be throttled.

然而,呼叫的方法不限于每秒1个,而是连续的.

使用Thread.sleep()可以实现限制,但我希望使用Guava而不是sleep().

我想知道使用Guava RateLimiter实现方法调用限制的正确方法.我已经检查了RateLimiter的文档并尝试使用相同但无法实现所需的结果.

Answer 1

您需要在每次调用时调用acquire()相同的内容RateLimiter,例如通过以下方式使其可用performOperation():

public class RateLimiterTest {
    public static void main(String[] args) {
        RateLimiter limiter = RateLimiter.create(1.0);
        for (int i = 0; i < 10; i++) {
            performOperation(limiter);
        }
    }

    private static void performOperation(RateLimiter limiter) {
        limiter.acquire();
        System.out.println(new Date() + ": Beep");
    }
}

结果是

Fri Aug 07 19:00:10 BST 2015:Beep
Fri Aug 07 19:00:11 BST 2015:Beep
Fri Aug 07 19:00:12 BST 2015:Beep
Fri Aug 07 07:00:13 BST 2015:Beep
Fri Aug 07 19:00:14 BST 2015:Beep
Fri Aug 07 19:00:15 BST 2015:Beep
Fri Aug 07 19:00:16 BST 2015:Beep
Fri Aug 07 19:00:17 BST 2015:Beep
Fri Aug 07 19 :00:18 BST 2015:Beep
Fri Aug 07 07:00:19 BST 2015:Beep