public abstract class OperationThread extends HazelcastManagedThread implements MetricsProvider
OperationRunner
.Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
OperationThread(String name,
int threadId,
OperationQueue queue,
ILogger logger,
HazelcastThreadGroup threadGroup,
NodeExtension nodeExtension,
boolean priority) |
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() |
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, OperationQueue queue, ILogger logger, HazelcastThreadGroup threadGroup, NodeExtension nodeExtension, boolean priority)
public int getThreadId()
public abstract OperationRunner getOperationRunner(int partitionId)
public final void run()
HazelcastManagedThread
run
in interface Runnable
run
in class HazelcastManagedThread
public void provideMetrics(MetricsRegistry metricsRegistry)
provideMetrics
in interface MetricsProvider
public final void shutdown()
public final void awaitTermination(int timeout, TimeUnit unit) throws InterruptedException
InterruptedException
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.