com.hazelcast.spi.impl.operationexecutor.impl

Class OperationExecutorImpl

java.lang.Object

com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl

All Implemented Interfaces:

MetricsProvider, OperationExecutor, LiveOperationsTracker, Consumer<Packet>

public final class OperationExecutorImpl
extends Object
implements OperationExecutor, MetricsProvider

A OperationExecutor that schedules:

1. partition specific operations to a specific partition-operation-thread (using a mod on the partition ID)
2. non specific operations to generic-operation-threads

The execute(Object, int, boolean) accepts an Object instead of a runnable to prevent needing to create wrapper runnables around tasks. This is done to reduce the amount of object litter and therefor reduce pressure on the GC.

There are 2 category of operation threads:

1. partition specific operation threads: these threads are responsible for executing e.g. a map.put. Operations for the same partition, always end up in the same thread.
2. generic operation threads: these threads are responsible for executing operations that are not specific to a partition, e.g. a heart beat.

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	IDLE_STRATEGY

Constructor Summary

Constructors

Constructor and Description
OperationExecutorImpl(HazelcastProperties properties, LoggingService loggerService, Address thisAddress, OperationRunnerFactory runnerFactory, NodeExtension nodeExtension, String hzName, ClassLoader configClassLoader)

Method Summary

Modifier and Type	Method and Description
void	accept(Packet packet) Performs this operation on the given argument.
void	execute(Operation op) Executes the given Operation at some point in the future.
void	execute(PartitionSpecificRunnable task) Executes the given PartitionSpecificRunnable at some point in the future.
void	executeOnPartitions(PartitionTaskFactory taskFactory, BitSet partitions) Executes a task from the taskFactory for each of the given partitions.
void	executeOnPartitionThreads(Runnable task) Executes the task on every partition thread.
long	getExecutedOperationCount() Returns the number of executed operations.
OperationRunner[]	getGenericOperationRunners() Gets all the generic operation handlers.
int	getGenericThreadCount() Returns the number of generic threads.
OperationRunner[]	getPartitionOperationRunners() Gets all the operation handlers for the partitions.
int	getPartitionThreadCount() Returns the number of partition threads.
int	getPartitionThreadId(int partitionId) Returns the ID of the partitionThread assigned to handle partition with given partitionId
int	getPriorityQueueSize()
int	getQueueSize()
int	getRunningOperationCount()
boolean	isInvocationAllowed(Operation op, boolean isAsync) Checks if the Operation is allowed to be invoked from the current thread.
boolean	isRunAllowed(Operation op) Checks if the Operation is allowed to run on the current thread.
void	populate(LiveOperations liveOperations) Populate the LiveOperations
void	provideMetrics(MetricsRegistry registry)
void	run(Operation operation) Runs the Operation on the calling thread.
void	runOrExecute(Operation op) Tries to run the Operation on the calling thread if allowed.
void	shutdown() Shuts down this OperationExecutor.
void	start() Starts this OperationExecutor.
int	toPartitionThreadIndex(int partitionId)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

IDLE_STRATEGY

public static final HazelcastProperty IDLE_STRATEGY

Constructor Detail

OperationExecutorImpl

public OperationExecutorImpl(HazelcastProperties properties,
                             LoggingService loggerService,
                             Address thisAddress,
                             OperationRunnerFactory runnerFactory,
                             NodeExtension nodeExtension,
                             String hzName,
                             ClassLoader configClassLoader)

Method Detail

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

getPartitionOperationRunners

public OperationRunner[] getPartitionOperationRunners()

Description copied from interface: OperationExecutor

Gets all the operation handlers for the partitions. Each partition will have its own operation handler. So if there are 271 partitions, then the size of the array will be 271.

Don't modify the content of the array!

Specified by:

getPartitionOperationRunners in interface OperationExecutor

Returns:

the operation handlers.

getGenericOperationRunners

public OperationRunner[] getGenericOperationRunners()

Description copied from interface: OperationExecutor

Gets all the generic operation handlers. The number of generic operation handlers depends on the number of generic threads.

Don't modify the content of the array!

Specified by:

getGenericOperationRunners in interface OperationExecutor

Returns:

the generic operation handlers.

populate

public void populate(LiveOperations liveOperations)

Description copied from interface: LiveOperationsTracker

Populate the LiveOperations

Specified by:

populate in interface LiveOperationsTracker

Parameters:

liveOperations - the LiveOperations to populate.

getRunningOperationCount

public int getRunningOperationCount()

Specified by:

getRunningOperationCount in interface OperationExecutor

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface OperationExecutor

getPriorityQueueSize

public int getPriorityQueueSize()

Specified by:

getPriorityQueueSize in interface OperationExecutor

getExecutedOperationCount

public long getExecutedOperationCount()

Description copied from interface: OperationExecutor

Returns the number of executed operations.

Specified by:

getExecutedOperationCount in interface OperationExecutor

getPartitionThreadCount

public int getPartitionThreadCount()

Description copied from interface: OperationExecutor

Returns the number of partition threads.

Specified by:

getPartitionThreadCount in interface OperationExecutor

Returns:

number of partition threads.

getGenericThreadCount

public int getGenericThreadCount()

Description copied from interface: OperationExecutor

Returns the number of generic threads.

Specified by:

getGenericThreadCount in interface OperationExecutor

Returns:

number of generic threads.

getPartitionThreadId

public int getPartitionThreadId(int partitionId)

Description copied from interface: OperationExecutor

Returns the ID of the partitionThread assigned to handle partition with given partitionId

Specified by:

getPartitionThreadId in interface OperationExecutor

Parameters:

partitionId - given partitionId

Returns:

ID of the partitionThread assigned to handle partition with given partitionId

execute

public void execute(Operation op)

Description copied from interface: OperationExecutor

Executes the given Operation at some point in the future.

Specified by:

execute in interface OperationExecutor

Parameters:

op - the operation to execute.

executeOnPartitions

public void executeOnPartitions(PartitionTaskFactory taskFactory,
                                BitSet partitions)

Description copied from interface: OperationExecutor

Executes a task from the taskFactory for each of the given partitions. The reason this method exists is to prevent a bubble of operations/tasks to be created on the work-queue if the regular OperationExecutor.execute(Operation) would be called in a loop. The consequence of this bubble is that no other operations can interleave and this can lead to very bad latency for the other operations. This method can be used to create Operations and Runnable's to be executed on a partition thread. No check is done if the partition is actually local or not!

Specified by:

executeOnPartitions in interface OperationExecutor

Parameters:

taskFactory - the PartitionTaskFactory responsible for creating tasks.

partitions - the partitions to execute tasks on. This BitSet should not modified after this method is called. For each of the partitions there is a bit indicating if a task should be executed on the partition.

execute

public void execute(PartitionSpecificRunnable task)

Description copied from interface: OperationExecutor

Executes the given PartitionSpecificRunnable at some point in the future.

Specified by:

execute in interface OperationExecutor

Parameters:

task - the task the execute.

accept

public void accept(Packet packet)

Description copied from interface: Consumer

Performs this operation on the given argument.

Specified by:

accept in interface Consumer<Packet>

Parameters:

packet - the input argument

executeOnPartitionThreads

public void executeOnPartitionThreads(Runnable task)

Description copied from interface: OperationExecutor

Executes the task on every partition thread.

Specified by:

executeOnPartitionThreads in interface OperationExecutor

Parameters:

task - the task the execute.

run

public void run(Operation operation)

Description copied from interface: OperationExecutor

Runs the Operation on the calling thread.

Specified by:

run in interface OperationExecutor

Parameters:

operation - the Operation to run.

runOrExecute

public void runOrExecute(Operation op)

Description copied from interface: OperationExecutor

Tries to run the Operation on the calling thread if allowed. Otherwise the operation is submitted for executing using OperationExecutor.execute(Operation).

Specified by:

runOrExecute in interface OperationExecutor

Parameters:

op - the Operation to run or execute.

isRunAllowed

public boolean isRunAllowed(Operation op)

Description copied from interface: OperationExecutor

Checks if the Operation is allowed to run on the current thread.

Specified by:

isRunAllowed in interface OperationExecutor

Parameters:

op - the Operation to check

Returns:

true if it is allowed, false otherwise.

isInvocationAllowed

public boolean isInvocationAllowed(Operation op,
                                   boolean isAsync)

Description copied from interface: OperationExecutor

Checks if the Operation is allowed to be invoked from the current thread. Invoking means that the operation can be executed on another thread, but that one is going to block for completion using the future.get/join etc. Blocking for completion can cause problems, e.g. when you hog a partition thread or deadlocks.

Specified by:

isInvocationAllowed in interface OperationExecutor

Parameters:

op - the Operation to check

isAsync - is the invocation async, if false invocation does not return a future to block on

Returns:

true if allowed, false otherwise.

toPartitionThreadIndex

public int toPartitionThreadIndex(int partitionId)

start

public void start()

Description copied from interface: OperationExecutor

Starts this OperationExecutor.

Specified by:

start in interface OperationExecutor

shutdown

public void shutdown()

Description copied from interface: OperationExecutor

Shuts down this OperationExecutor. Any pending tasks are discarded.

Specified by:

shutdown in interface OperationExecutor

toString

public String toString()

Overrides:

toString in class Object