public static final class RequestExecutor.ScheduledRequest extends java.lang.Object implements RequestExecutor.Request
RequestExecutor.Request
implementation that reschedules itself after execution, attempting to run periodically
at the provided rate, until cancelled.Constructor and Description |
---|
ScheduledRequest(RequestExecutor.Request request,
java.time.Duration rate,
com.codahale.metrics.Timer timer) |
ScheduledRequest(RequestExecutor.Request request,
long rateNanos,
com.codahale.metrics.Timer timer) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
execute(RequestExecutor.RequestPermit permit)
Execute this request.
|
long |
getRateNanos() |
public ScheduledRequest(RequestExecutor.Request request, java.time.Duration rate, com.codahale.metrics.Timer timer)
public ScheduledRequest(RequestExecutor.Request request, long rateNanos, com.codahale.metrics.Timer timer)
public final void execute(RequestExecutor.RequestPermit permit)
RequestExecutor.Request
RequestExecutor.RequestPermit.release()
must be called when execution is complete.execute
in interface RequestExecutor.Request
permit
- the RequestExecutor.RequestPermit
associated with this RequestExecutor.Request
.public final void cancel()
public final long getRateNanos()