com.hazelcast.spi.hotrestart.impl

Class RamStoreRestartLoop

java.lang.Object

com.hazelcast.spi.hotrestart.impl.RamStoreRestartLoop

public class RamStoreRestartLoop
extends Object

Contains the main loop executed by the threads that call into the RamStore during the Hot Restart process.

Field Summary

Fields

Modifier and Type	Field and Description
static com.hazelcast.util.concurrent.IdleStrategy	DRAIN_IDLER
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[]	keyHandleSenders
com.hazelcast.internal.util.concurrent.ConcurrentConveyorSingleQueue<RestartItem>[][]	keyReceivers
static long	MAX_PARK_MICROS Max park microseconds while awaiting new items in the queue.
static int	MIN_QUEUE_CAPACITY
static int	QUEUE_CAPACITY_BUDGET
static int	SPIN_COUNT How many times to busy-spin while awaiting new items in the queue.
com.hazelcast.internal.util.concurrent.ConcurrentConveyorSingleQueue<RestartItem>[][]	valueReceivers
static int	YIELD_COUNT How many times to yield while awaiting new items in the queue.

Constructor Summary

Constructors

Constructor and Description
RamStoreRestartLoop(int storeCount, int threadCount, RamStoreRegistry reg, com.hazelcast.logging.ILogger logger)

Method Summary

Modifier and Type	Method and Description
void	run(int threadIndex)

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_CAPACITY_BUDGET

public static final int QUEUE_CAPACITY_BUDGET

See Also:

Constant Field Values

MIN_QUEUE_CAPACITY

public static final int MIN_QUEUE_CAPACITY

See Also:

Constant Field Values

SPIN_COUNT

public static final int SPIN_COUNT

How many times to busy-spin while awaiting new items in the queue.

See Also:

Constant Field Values

YIELD_COUNT

public static final int YIELD_COUNT

How many times to yield while awaiting new items in the queue.

See Also:

Constant Field Values

MAX_PARK_MICROS

public static final long MAX_PARK_MICROS

Max park microseconds while awaiting new items in the queue.

See Also:

Constant Field Values

DRAIN_IDLER

public static final com.hazelcast.util.concurrent.IdleStrategy DRAIN_IDLER

keyReceivers

public final com.hazelcast.internal.util.concurrent.ConcurrentConveyorSingleQueue<RestartItem>[][] keyReceivers

keyHandleSenders

public final com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[] keyHandleSenders

valueReceivers

public final com.hazelcast.internal.util.concurrent.ConcurrentConveyorSingleQueue<RestartItem>[][] valueReceivers

Constructor Detail

RamStoreRestartLoop

public RamStoreRestartLoop(int storeCount,
                           int threadCount,
                           RamStoreRegistry reg,
                           com.hazelcast.logging.ILogger logger)

Method Detail

run

public final void run(int threadIndex)