Package me.ahoo.cosid.machine

Class DefaultClockBackwardsSynchronizer

java.lang.Object

me.ahoo.cosid.machine.DefaultClockBackwardsSynchronizer

All Implemented Interfaces:

ClockBackwardsSynchronizer

public class DefaultClockBackwardsSynchronizer
extends Object
implements ClockBackwardsSynchronizer

Default Clock Backwards Synchronizer.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BROKEN_THRESHOLD
static final int	DEFAULT_SPIN_THRESHOLD

Fields inherited from interface me.ahoo.cosid.machine.ClockBackwardsSynchronizer

DEFAULT

Constructor Summary

Constructors

Constructor	Description
DefaultClockBackwardsSynchronizer()
DefaultClockBackwardsSynchronizer(int spinThreshold, int brokenThreshold)

Method Summary

Modifier and Type	Method	Description
void	sync(long lastTimestamp)	Synchronizes clock by waiting until current time exceeds lastTimestamp.
void	syncUninterruptibly(long lastTimestamp)	Synchronizes clock without throwing InterruptedException.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SPIN_THRESHOLD

public static final int DEFAULT_SPIN_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_BROKEN_THRESHOLD

public static final int DEFAULT_BROKEN_THRESHOLD

See Also:

• Constant Field Values

Constructor Details

DefaultClockBackwardsSynchronizer

public DefaultClockBackwardsSynchronizer()

DefaultClockBackwardsSynchronizer

public DefaultClockBackwardsSynchronizer(int spinThreshold,
 int brokenThreshold)

Method Details

sync

public void sync(long lastTimestamp)
          throws InterruptedException,
ClockTooManyBackwardsException

Description copied from interface: ClockBackwardsSynchronizer

Synchronizes clock by waiting until current time exceeds lastTimestamp.

Specified by:

sync in interface ClockBackwardsSynchronizer

Parameters:

lastTimestamp - the last timestamp that was generated

Throws:

InterruptedException - if thread is interrupted while waiting

ClockTooManyBackwardsException - if clock backwards exceeds threshold

syncUninterruptibly

public void syncUninterruptibly(long lastTimestamp)
                         throws ClockTooManyBackwardsException

Description copied from interface: ClockBackwardsSynchronizer

Synchronizes clock without throwing InterruptedException.

Specified by:

syncUninterruptibly in interface ClockBackwardsSynchronizer

Parameters:

lastTimestamp - the last timestamp that was generated

Throws:

ClockTooManyBackwardsException - if clock backwards exceeds threshold