gobblin.util.limiter

Class TimeBasedLimiter

java.lang.Object

gobblin.util.limiter.NonRefillableLimiter

gobblin.util.limiter.TimeBasedLimiter

All Implemented Interfaces:

Limiter

public class TimeBasedLimiter
extends NonRefillableLimiter

An implementation of Limiter that limits the time elapsed for some events.

This implementation uses a task scheduled in a ScheduledThreadPoolExecutor that will fire once after a given amount of time has elapsed. The task once fired, will flip a boolean flag that tells if permits should be issued. The flag is initially set to true. Thus, no permits are issued once the flag is flipped after the given amount of time has elapsed.

acquirePermits(long) will return false once the time limit is reached. Permit refills are not supported in this implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TimeBasedLimiter.Factory

Field Summary

Fields inherited from class gobblin.util.limiter.NonRefillableLimiter

NO_OP_CLOSEABLE

Constructor Summary

Constructors

Constructor and Description
TimeBasedLimiter(long timeLimit)
TimeBasedLimiter(long timeLimit, TimeUnit timeUnit)

Method Summary

Modifier and Type	Method and Description
Closeable	acquirePermits(long permits) Acquire a given number of permits.
void	start() Start the Limiter.
void	stop() Stop the Limiter.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeBasedLimiter

public TimeBasedLimiter(long timeLimit)

TimeBasedLimiter

public TimeBasedLimiter(long timeLimit,
                        TimeUnit timeUnit)

Method Detail

start

public void start()

Description copied from interface: Limiter

Start the Limiter. See Limiter.stop()

acquirePermits

public Closeable acquirePermits(long permits)
                         throws InterruptedException

Description copied from interface: Limiter

Acquire a given number of permits.

Depending on the implementation, the caller of this method may be blocked. It is also up to the caller to decide how to deal with the return value.

Specified by:

acquirePermits in interface Limiter

Overrides:

acquirePermits in class NonRefillableLimiter

Parameters:

permits - number of permits to get

Returns:

a Closeable instance if the requested permits have been successfully acquired, or null if otherwise; in the former case, calling Closeable.close() on the returned Closeable instance will release the acquired permits.

Throws:

InterruptedException - if the caller is interrupted while being blocked

stop

public void stop()

Description copied from interface: Limiter

Stop the Limiter. See Limiter.start()