public abstract class OperationThread extends HazelcastManagedThread
OperationRunner
.Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
OperationThread(String name,
int threadId,
ScheduleQueue scheduleQueue,
ILogger logger,
HazelcastThreadGroup threadGroup,
NodeExtension nodeExtension) |
Modifier and Type | Method and Description |
---|---|
void |
awaitTermination(int timeout,
TimeUnit unit) |
OperationRunner |
getCurrentOperationRunner() |
abstract OperationRunner |
getOperationRunner(int partitionId) |
int |
getThreadId() |
void |
run()
Manages the thread lifecycle and can be overridden to customize if needed.
|
void |
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 OperationThread(String name, int threadId, ScheduleQueue scheduleQueue, ILogger logger, HazelcastThreadGroup threadGroup, NodeExtension nodeExtension)
public OperationRunner getCurrentOperationRunner()
public abstract OperationRunner getOperationRunner(int partitionId)
public final void run()
HazelcastManagedThread
run
in interface Runnable
run
in class HazelcastManagedThread
public final void shutdown()
public final void awaitTermination(int timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public int getThreadId()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.