com.hazelcast.spi.impl.operationexecutor.impl

Class OperationExecutorImpl

java.lang.Object

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

All Implemented Interfaces:

MetricsProvider, OperationExecutor, PacketHandler

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	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	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()
void	handle(Packet packet) Signals the PacketHandler that there is a packet to be handled.
void	interruptPartitionThreads() Interrupts the partition threads.
boolean	isInvocationAllowed(Operation op, boolean isAsync) Checks if the Operation is allowed to be invoked from the current thread.
boolean	isOperationThread() Checks if the current thread is an Operation thread.
boolean	isRunAllowed(Operation op) Checks if the Operation is allowed to run on the current thread.
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	scan(LiveOperations result)
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.

scan

public void scan(LiveOperations result)

Specified by:

scan in interface OperationExecutor

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.

isOperationThread

public boolean isOperationThread()

Description copied from interface: OperationExecutor

Checks if the current thread is an Operation thread.

Specified by:

isOperationThread in interface OperationExecutor

Returns:

true if is an Operation thread, false otherwise.

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.

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.

handle

public void handle(Packet packet)

Description copied from interface: PacketHandler

Signals the PacketHandler that there is a packet to be handled.

Specified by:

handle in interface PacketHandler

Parameters:

packet - the response packet to handle

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.

interruptPartitionThreads

public void interruptPartitionThreads()

Description copied from interface: OperationExecutor

Interrupts the partition threads.

Specified by:

interruptPartitionThreads in interface OperationExecutor

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