com.blazemeter.jmeter.threads.concurrency

Class ConcurrencyThreadGroup

java.lang.Object

org.apache.jmeter.testelement.AbstractTestElement

org.apache.jmeter.threads.AbstractThreadGroup

com.blazemeter.jmeter.threads.AbstractDynamicThreadGroupModel

com.blazemeter.jmeter.threads.AbstractDynamicThreadGroup

com.blazemeter.jmeter.threads.concurrency.ConcurrencyThreadGroup

All Implemented Interfaces:

Serializable, Cloneable, org.apache.jmeter.control.Controller, org.apache.jmeter.gui.Searchable, org.apache.jmeter.testelement.TestElement, org.apache.jmeter.testelement.TestStateListener, org.apache.jmeter.threads.JMeterThreadMonitor, org.apache.jmeter.threads.TestCompilerHelper

public class ConcurrencyThreadGroup
extends AbstractDynamicThreadGroup

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	MIN_CHECK_TIME

Fields inherited from class com.blazemeter.jmeter.threads.AbstractDynamicThreadGroup

threadStarter, UNIT, UNIT_MINUTES, UNIT_SECONDS

Fields inherited from class com.blazemeter.jmeter.threads.AbstractDynamicThreadGroupModel

HOLD, ITERATIONS, LOG_FILENAME, logFile, RAMP_UP, running, STEPS, TARGET_LEVEL, threads, WAIT_TO_DIE

Fields inherited from class org.apache.jmeter.threads.AbstractThreadGroup

MAIN_CONTROLLER, NUM_THREADS, ON_SAMPLE_ERROR, ON_SAMPLE_ERROR_CONTINUE, ON_SAMPLE_ERROR_START_NEXT_LOOP, ON_SAMPLE_ERROR_STOPTEST, ON_SAMPLE_ERROR_STOPTEST_NOW, ON_SAMPLE_ERROR_STOPTHREAD

Fields inherited from interface org.apache.jmeter.testelement.TestElement

COMMENTS, ENABLED, GUI_CLASS, NAME, TEST_CLASS

Constructor Summary

Constructors

Constructor and Description
ConcurrencyThreadGroup()

Method Summary

Modifier and Type	Method and Description
long	getConcurrency()
int	getNumThreads()
protected Thread	getThreadStarter(int groupIndex, org.apache.jmeter.threads.ListenerNotifier listenerNotifier, org.apache.jorphan.collections.ListedHashTree testTree, org.apache.jmeter.engine.StandardJMeterEngine engine)
boolean	isLimitReached()
void	threadFinished(org.apache.jmeter.threads.JMeterThread thread)
void	threadStarted(org.apache.jmeter.threads.JMeterThread thread)
boolean	tooMuchConcurrency()
void	waitThreadStopped() If threads is empty we wait on condition for DEFAULT_TEMPORISATION millis to be notified, otherwise we wait for 1s

Methods inherited from class com.blazemeter.jmeter.threads.AbstractDynamicThreadGroup

getUnit, getUnitFactor, getUnitStr, getUnitStr, isRunning, joinThreadFrom, setUnit, start, startNextLoop, stop, stopThread, tellThreadsToStop, verifyThreadsStopped, waitThreadsStopped

Methods inherited from class com.blazemeter.jmeter.threads.AbstractDynamicThreadGroupModel

addThread, getHold, getHoldSeconds, getIterationsLimit, getIterationsLimitAsLong, getLogFilename, getNumberOfThreads, getRampUp, getRampUpSeconds, getSteps, getStepsAsLong, getTargetLevel, getTargetLevelAsDouble, getTargetLevelAsInt, getTargetLevelFactored, numberOfActiveThreads, saveLogRecord, setHold, setIterationsLimit, setLogFilename, setRampUp, setSteps, setTargetLevel, testEnded, testEnded, testStarted, testStarted

Methods inherited from class org.apache.jmeter.threads.AbstractThreadGroup

addIterationListener, addTestElement, addTestElementOnce, getOnErrorStartNextLoop, getOnErrorStopTest, getOnErrorStopTestNow, getOnErrorStopThread, getSamplerController, initialize, isDone, next, removeIterationListener, setNumThreads, setSamplerController, triggerEndOfLoop

Methods inherited from class org.apache.jmeter.testelement.AbstractTestElement

addPropertiesValues, addProperty, addProperty, canRemove, clear, clearTemporary, clearTestElementChildren, clone, emptyTemporary, equals, getComment, getName, getProperty, getPropertyAsBoolean, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsInt, getPropertyAsLong, getPropertyAsLong, getPropertyAsString, getPropertyAsString, getSearchableTokens, getThreadContext, getThreadName, hashCode, isEnabled, isRunningVersion, isTemporary, logProperties, mergeIn, propertyIterator, recoverRunningVersion, removeProperty, setComment, setEnabled, setName, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setRunningVersion, setTemporary, setThreadContext, setThreadName, traverse, traverseCollection, traverseMap, traverseProperty

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.jmeter.testelement.TestElement

canRemove, clear, clearTestElementChildren, clone, getComment, getName, getProperty, getPropertyAsBoolean, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsInt, getPropertyAsLong, getPropertyAsLong, getPropertyAsString, getPropertyAsString, getThreadContext, getThreadName, isEnabled, isRunningVersion, isTemporary, propertyIterator, recoverRunningVersion, removeProperty, setComment, setEnabled, setName, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setRunningVersion, setTemporary, setThreadContext, setThreadName, traverse

Field Detail

MIN_CHECK_TIME

public static final long MIN_CHECK_TIME

See Also:

Constant Field Values

Constructor Detail

ConcurrencyThreadGroup

public ConcurrencyThreadGroup()

Method Detail

getThreadStarter

protected Thread getThreadStarter(int groupIndex,
                                  org.apache.jmeter.threads.ListenerNotifier listenerNotifier,
                                  org.apache.jorphan.collections.ListedHashTree testTree,
                                  org.apache.jmeter.engine.StandardJMeterEngine engine)

Specified by:

getThreadStarter in class AbstractDynamicThreadGroup

waitThreadStopped

public void waitThreadStopped()

If threads is empty we wait on condition for DEFAULT_TEMPORISATION millis to be notified, otherwise we wait for 1s

getNumThreads

public int getNumThreads()

Overrides:

getNumThreads in class org.apache.jmeter.threads.AbstractThreadGroup

isLimitReached

public boolean isLimitReached()

Specified by:

isLimitReached in class AbstractDynamicThreadGroup

threadStarted

public void threadStarted(org.apache.jmeter.threads.JMeterThread thread)

threadFinished

public void threadFinished(org.apache.jmeter.threads.JMeterThread thread)

Specified by:

threadFinished in interface org.apache.jmeter.threads.JMeterThreadMonitor

Overrides:

threadFinished in class AbstractDynamicThreadGroup

getConcurrency

public long getConcurrency()

tooMuchConcurrency

public boolean tooMuchConcurrency()