Guave ist RateLimiter pro Minuten statt Sekunden?

Gibt es eine Klasse namens SmoothRateLimiter.SmoothBursty innen Guava-Bibliothek, die gewünschte Verhalten, aber es hat Paket den lokalen Zugriff, also können wir es nicht verwenden, direkt.
Es gibt auch einen Github-issue, damit der Zugriff auf die Klasse public: https://github.com/google/guava/issues/1974

Wenn Sie nicht bereit sind zu warten, bis Sie eine neue version von RateLimiter dann können Sie mit Reflexion zu instanziieren SmoothBursty rate limiter. So etwas wie dies funktionieren sollte:

Class<?> sleepingStopwatchClass = Class.forName("com.google.common.util.concurrent.RateLimiter$SleepingStopwatch");
Method createStopwatchMethod = sleepingStopwatchClass.getDeclaredMethod("createFromSystemTimer");
createStopwatchMethod.setAccessible(true);
Object stopwatch = createStopwatchMethod.invoke(null);

Class<?> burstyRateLimiterClass = Class.forName("com.google.common.util.concurrent.SmoothRateLimiter$SmoothBursty");
Constructor<?> burstyRateLimiterConstructor = burstyRateLimiterClass.getDeclaredConstructors()[0];
burstyRateLimiterConstructor.setAccessible(true);

RateLimiter result = (RateLimiter) burstyRateLimiterConstructor.newInstance(stopwatch, maxBurstSeconds);
result.setRate(permitsPerSecond);
return result;

Ja, neue version von Guave vielleicht Bremsen Sie Ihren code, aber wenn Sie bereit sind, zu akzeptieren, dass dieses Risiko könnte der Weg zu gehen.

Ich glaube, ich kam auf das gleiche problem wie in der ursprünglichen Frage, und basiert auf Louis Wasserman ist Kommentar dies ist, was ich hatte:

import com.google.common.util.concurrent.RateLimiter;
import java.time.Duration;

public class Titrator {

    private final int numDosesPerPeriod;
    private final RateLimiter rateLimiter;
    private long numDosesAvailable;
    private transient final Object doseLock;

    public Titrator(int numDosesPerPeriod, Duration period) {
        this.numDosesPerPeriod = numDosesPerPeriod;
        double numSeconds = period.getSeconds() + period.getNano() / 1000000000d;
        rateLimiter = RateLimiter.create(1 / numSeconds);
        numDosesAvailable = 0L;
        doseLock = new Object();
    }

    /**
     * Consumes a dose from this titrator, blocking until a dose is available.
     */
    public void consume() {
        synchronized (doseLock) {
            if (numDosesAvailable == 0) { //then refill
                rateLimiter.acquire();
                numDosesAvailable += numDosesPerPeriod;
            }
            numDosesAvailable--;
        }
    }

}

Die Dosis gemessen, die von der Titrator ist Analog zu einer Erlaubnis von einem RateLimiter. Diese Implementierung wird davon ausgegangen, dass, wenn Sie verbrauchen Ihre erste Dosis, die Uhr beginnt zu ticken auf der Anwendungsdauer. Sie können verbrauchen max Dosen pro Periode so schnell wie Sie wollen, aber, wenn Sie erreichen Ihre max, Sie haben zu warten, bis die Frist verstreicht, bevor man eine weitere Dosis.

Für eine tryConsume() analog zu RateLimiter ist tryAcquire würden Sie überprüfen, dass numDosesAvailable ist positiv.

Unsere Lösung HIERFÜR ist das erstellen einer RateLimiter Klasse auf unserer eigenen, und ändern Sie die Zeit-Einheiten. Zum Beispiel, in unserem Fall, wir wollen ein tägliches limit.

Alles das gleiche ist, wie die RateLimiter außer für den Erwerb(Genehmigungen) - Funktion, wo wir verändert die Zeiteinheit in (Doppel -) TimeUnit.SEKUNDEN.toMicros(1L), um die Einheit, die wir uns wünschen. In unserem Fall ändern wir das in TimeUnit.Tag für den täglichen Grenzen.

Dann erstellen wir unsere eigenen glatten RateLimiter und in der doSetRate(Doppel-permitsPerDay, lange nowMicros) und doGetRate () - Funktion, die wir auch ändern Sie die Zeiteinheit.