public final class PartitionOperationThread extends OperationThread
OperationThread
that executes Operations for a particular partition, e.g. a map.get operation.Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
PartitionOperationThread(String name,
int threadId,
ScheduleQueue scheduleQueue,
ILogger logger,
HazelcastThreadGroup threadGroup,
NodeExtension nodeExtension,
OperationRunner[] partitionOperationRunners) |
Modifier and Type | Method and Description |
---|---|
OperationRunner |
getOperationRunner(int partitionId)
For each partition there is a
OperationRunner instance. |
awaitTermination, getCurrentOperationRunner, getThreadId, run, shutdown
afterRun, beforeRun, executeRun, setContextClassLoader
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
public PartitionOperationThread(String name, int threadId, ScheduleQueue scheduleQueue, ILogger logger, HazelcastThreadGroup threadGroup, NodeExtension nodeExtension, OperationRunner[] partitionOperationRunners)
public OperationRunner getOperationRunner(int partitionId)
OperationRunner
instance. So we need to
find the right one based on the partition-id.getOperationRunner
in class OperationThread
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.