Guava - RateLimiter

packagecom.mmall.concurrency.example.rateLimiter;
importcom.google.common.util.concurrent.RateLimiter;
importlombok.extern.slf4j.Slf4j;
importjava.util.concurrent.TimeUnit;
@Slf4jpublicclassRateLimiterExample1 {
// 因为创建的时候规定 1 秒 5 个令牌，即换算成 1 个令牌 200 毫秒。privatestaticRateLimiterrateLimiter=RateLimiter.create(5);
publicstaticvoidmain(String[] args) throwsException {
for (intindex=0; index<100; index++) {
if (rateLimiter.tryAcquire(190, TimeUnit.MILLISECONDS)) {
handle(index);
            }
        }
    }
privatestaticvoidhandle(inti) {
log.info("{}", i);
    }
}

packagecom.mmall.concurrency.example.rateLimiter;
importcom.google.common.util.concurrent.RateLimiter;
importlombok.extern.slf4j.Slf4j;
importjava.util.concurrent.TimeUnit;
@Slf4jpublicclassRateLimiterExample2 {
privatestaticRateLimiterrateLimiter=RateLimiter.create(5);
publicstaticvoidmain(String[] args) throwsException {
for (intindex=0; index<100; index++) {
rateLimiter.acquire();
handle(index);
        }
    }
privatestaticvoidhandle(inti) {
log.info("{}", i);
    }
}

// 输出18:04:03.190 [main] INFOc.m.c.example.rateLimiter.test9-018:04:03.387 [main] INFOc.m.c.example.rateLimiter.test9-118:04:03.587 [main] INFOc.m.c.example.rateLimiter.test9-218:04:03.787 [main] INFOc.m.c.example.rateLimiter.test9-318:04:03.988 [main] INFOc.m.c.example.rateLimiter.test9-418:04:04.188 [main] INFOc.m.c.example.rateLimiter.test9-518:04:04.388 [main] INFOc.m.c.example.rateLimiter.test9-618:04:04.588 [main] INFOc.m.c.example.rateLimiter.test9-718:04:04.789 [main] INFOc.m.c.example.rateLimiter.test9-818:04:04.988 [main] INFOc.m.c.example.rateLimiter.test9-9...