Class DefaultMockTicker

java.lang.Object

io.netty.util.concurrent.DefaultMockTicker

All Implemented Interfaces:

MockTicker, Ticker

final class DefaultMockTicker
extends Object
implements MockTicker

The default MockTicker implementation.

Field Summary

Fields

Modifier and Type	Field	Description
private final ReentrantLock	lock
private final AtomicLong	nanoTime
private final Condition	sleeperCondition
private final Set<Thread>	sleepers
private final Condition	tickCondition

Constructor Summary

Constructors

Constructor	Description
DefaultMockTicker()

Method Summary

Modifier and Type	Method	Description
void	advance(long amount, TimeUnit unit)	Advances the current Ticker.nanoTime() by the given amount of time.
void	awaitSleepingThread(Thread thread)	Wait for the given thread to enter the sleep(long, TimeUnit) method, and block.
long	nanoTime()	The time elapsed since initialization of this class in nanoseconds.
void	sleep(long delay, TimeUnit unit)	Waits until the given amount of time goes by.

Methods inherited from class Object

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

Methods inherited from interface MockTicker

advanceMillis, initialNanoTime

Methods inherited from interface Ticker

sleepMillis

Field Details

lock

private final ReentrantLock lock

tickCondition

private final Condition tickCondition

sleeperCondition

private final Condition sleeperCondition

nanoTime

private final AtomicLong nanoTime

sleepers

private final Set<Thread> sleepers

Constructor Details

DefaultMockTicker

DefaultMockTicker()

Method Details

nanoTime

public long nanoTime()

Description copied from interface: Ticker

The time elapsed since initialization of this class in nanoseconds. This may return a negative number just like System.nanoTime().

Specified by:

nanoTime in interface Ticker

sleep

public void sleep(long delay,
 TimeUnit unit)
           throws InterruptedException

Description copied from interface: Ticker

Waits until the given amount of time goes by.

Specified by:

sleep in interface Ticker

Parameters:

delay - the amount of delay.

unit - the TimeUnit of delay.

Throws:

InterruptedException

See Also:

• Thread.sleep(long)

awaitSleepingThread

public void awaitSleepingThread(Thread thread)
                         throws InterruptedException

Wait for the given thread to enter the sleep(long, TimeUnit) method, and block.

Throws:

InterruptedException

advance

public void advance(long amount,
 TimeUnit unit)

Description copied from interface: MockTicker

Advances the current Ticker.nanoTime() by the given amount of time.

Specified by:

advance in interface MockTicker

Parameters:

amount - the amount of time to advance this ticker by.

unit - the TimeUnit of amount.