alluxio.time

Class SteppingThreadSleeper

java.lang.Object

alluxio.time.SteppingThreadSleeper

All Implemented Interfaces:

Sleeper

public final class SteppingThreadSleeper
extends Object
implements Sleeper

A progressive sleeper that wakes up multiple times during sleep to check if the requested sleep duration has changed, and adjust its sleep duration accordingly.

Field Summary

Fields

Modifier and Type	Field and Description
static SteppingThreadSleeper	INSTANCE

Constructor Summary

Constructors

Constructor and Description
SteppingThreadSleeper(Sleeper internalSleeper, java.time.Clock clock) Creates a new instance of SteppingThreadSleeper.

Method Summary

Modifier and Type	Method and Description
void	setSleepStepMs(long sleepStepMs) Sets the sleep step.
void	sleep(java.time.Duration duration) Sleeps for the given duration.
void	sleep(java.util.function.Supplier<java.time.Duration> durationSupplier) Sleeps for given duration but period wake-up by new interval supplier.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final SteppingThreadSleeper INSTANCE

Constructor Detail

SteppingThreadSleeper

public SteppingThreadSleeper(Sleeper internalSleeper,
                             java.time.Clock clock)

Creates a new instance of SteppingThreadSleeper.

Parameters:

internalSleeper - the internal sleeper

clock - for telling the current time

Method Detail

sleep

public void sleep(java.time.Duration duration)
           throws InterruptedException

Description copied from interface: Sleeper

Sleeps for the given duration.

Specified by:

sleep in interface Sleeper

Parameters:

duration - the duration to sleep for

Throws:

InterruptedException - if the sleep is interrupted

sleep

public void sleep(java.util.function.Supplier<java.time.Duration> durationSupplier)
           throws InterruptedException

Description copied from interface: Sleeper

Sleeps for given duration but period wake-up by new interval supplier.

Specified by:

sleep in interface Sleeper

Parameters:

durationSupplier - New sleep interval supplier

Throws:

InterruptedException

setSleepStepMs

public void setSleepStepMs(long sleepStepMs)

Sets the sleep step.

Parameters:

sleepStepMs - the sleep step