com.hazelcast.spi.impl.operationexecutor.impl

Class OperationThread

java.lang.Object

java.lang.Thread

com.hazelcast.util.executor.HazelcastManagedThread

com.hazelcast.spi.impl.operationexecutor.impl.OperationThread

All Implemented Interfaces:

MetricsProvider, Runnable

Direct Known Subclasses:

GenericOperationThread, PartitionOperationThread

public abstract class OperationThread
extends HazelcastManagedThread
implements MetricsProvider

The OperationThread is responsible for processing operations, packets containing operations and runnable's.

There are 2 flavors of OperationThread: - threads that deal with operations for a specific partition - threads that deal with non partition specific tasks

The actual processing of an operation is forwarded to the OperationRunner.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
OperationThread(String name, int threadId, OperationQueue queue, ILogger logger, HazelcastThreadGroup threadGroup, NodeExtension nodeExtension, boolean priority)

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitTermination(int timeout, TimeUnit unit)
abstract OperationRunner	getOperationRunner(int partitionId)
int	getThreadId()
void	provideMetrics(MetricsRegistry metricsRegistry)
void	run() Manages the thread lifecycle and can be overridden to customize if needed.
void	shutdown()

Methods inherited from class com.hazelcast.util.executor.HazelcastManagedThread

afterRun, beforeRun, executeRun, setContextClassLoader

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationThread

public OperationThread(String name,
               int threadId,
               OperationQueue queue,
               ILogger logger,
               HazelcastThreadGroup threadGroup,
               NodeExtension nodeExtension,
               boolean priority)

Method Detail

getThreadId

public int getThreadId()

getOperationRunner

public abstract OperationRunner getOperationRunner(int partitionId)

run

public final void run()

Description copied from class: HazelcastManagedThread

Manages the thread lifecycle and can be overridden to customize if needed.

Specified by:

run in interface Runnable

Overrides:

run in class HazelcastManagedThread

provideMetrics

public void provideMetrics(MetricsRegistry metricsRegistry)

Specified by:

provideMetrics in interface MetricsProvider

shutdown

public final void shutdown()

awaitTermination

public final void awaitTermination(int timeout,
                    TimeUnit unit)
                            throws InterruptedException

Throws:

InterruptedException