public class ThreadsStatusDisplayFilter extends teetime.framework.AbstractConsumerStage<ThreadsStatusRecord>
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DAEMON_THREADS |
static java.lang.String |
PEAK_THREADS |
static java.lang.String |
THREADS |
static java.lang.String |
TOTAL_THREADS |
Constructor and Description |
---|
ThreadsStatusDisplayFilter(int numberOfEntries,
java.util.concurrent.TimeUnit recordsTimeUnit)
Creates a new instance of this filter.
|
Modifier and Type | Method and Description |
---|---|
void |
execute(ThreadsStatusRecord record)
This method represents the input port receiving the incoming events.
|
XYPlot |
getXYPlot() |
createInputPort, execute, getInputPort
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public static final java.lang.String TOTAL_THREADS
public static final java.lang.String THREADS
public static final java.lang.String DAEMON_THREADS
public static final java.lang.String PEAK_THREADS
public ThreadsStatusDisplayFilter(int numberOfEntries, java.util.concurrent.TimeUnit recordsTimeUnit)
numberOfEntries
- Maximal number of entries in a XYPlotrecordsTimeUnit
- Time unit to interpret the timestamp of a record passed to the input portpublic void execute(ThreadsStatusRecord record)
execute
in class teetime.framework.AbstractConsumerStage<ThreadsStatusRecord>
record
- The record to display and relay.public XYPlot getXYPlot()
Copyright 2020 Kieker Project, http://kieker-monitoring.net