package com.yuzhouwan.bigdata.redis.rate.limit;

import com.google.common.util.concurrent.RateLimiter;
import org.junit.Test;

import static org.junit.Assert.assertEquals;

/**
 * Copyright @ 2018 yuzhouwan.com
 * All right reserved.
 * Function：Guava Rate Limiter Test
 *
 * @author Benedict Jin
 * @since 2018/1/9
 */
public class GuavaRateLimiterTest {

    private static final int PERMITS_PER_SECOND = 2;
    private static final int PERMITS_NEEDS_PER_OPERATION = 1;
    private static final int SHOULD_WAIT_MILLISECONDS = 1000;

    @Test
    public void normal() {
        RateLimiter rateLimiter = RateLimiter.create(PERMITS_PER_SECOND);
        long startTime = System.currentTimeMillis();
        rateLimiter.acquire(PERMITS_NEEDS_PER_OPERATION);
        System.out.println("Operation 1.");
        rateLimiter.acquire(PERMITS_NEEDS_PER_OPERATION);
        System.out.println("Operation 2.");
        rateLimiter.acquire(PERMITS_NEEDS_PER_OPERATION);
        System.out.println("Operation 3.");
        long usedTime = System.currentTimeMillis() - startTime;
        System.out.println(usedTime + " ms");
        assertEquals(true, usedTime >= SHOULD_WAIT_MILLISECONDS);
        System.out.println(String.format("%s >= %s" + " ms", usedTime, SHOULD_WAIT_MILLISECONDS));
    }
}

@@ -526,16 +526,84 @@
  = 1000;
+%0A    private static final int FOR_FAULT_TOLERANT_MILLISECONDS = 200;
 %0A%0A    @T
@@ -1212,16 +1212,50 @@
 sedTime 
++ FOR_FAULT_TOLERANT_MILLISECONDS 
 %3E= SHOUL

Add fault tolerant time into GuavaRateLimiter testcase