org.spf4j.failsafe

Class GuavaRateLimiter

java.lang.Object

org.spf4j.failsafe.GuavaRateLimiter

All Implemented Interfaces:

PermitSupplier

public final class GuavaRateLimiter
extends Object
implements PermitSupplier

Author:

Zoltan Farkas

Constructor Summary

Constructors

Constructor and Description
GuavaRateLimiter(com.google.common.util.concurrent.RateLimiter limiter)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.RateLimiter	getLimiter()
String	toString()
boolean	tryAcquire(int nrPermits, long deadlineNanos)
boolean	tryAcquire(int nrPermits, long timeout, TimeUnit unit) try to acquire a number of permits.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.spf4j.concurrent.PermitSupplier

acquire, acquire, toSemaphore, tryAcquire

Constructor Detail

GuavaRateLimiter

public GuavaRateLimiter(com.google.common.util.concurrent.RateLimiter limiter)

Method Detail

tryAcquire

public boolean tryAcquire(int nrPermits,
                          long deadlineNanos)
                   throws InterruptedException

Specified by:

tryAcquire in interface PermitSupplier

Throws:

InterruptedException

tryAcquire

public boolean tryAcquire(int nrPermits,
                          long timeout,
                          TimeUnit unit)
                   throws InterruptedException

Description copied from interface: PermitSupplier

try to acquire a number of permits.

Specified by:

tryAcquire in interface PermitSupplier

Parameters:

nrPermits - number of permits to acquire.

timeout - time to wait for permits to become available.

unit - units of time.

Returns:

true if permits acquired, false if timed out.

Throws:

InterruptedException - - operation interrupted.

getLimiter

public com.google.common.util.concurrent.RateLimiter getLimiter()

toString

public String toString()

Overrides:

toString in class Object