com.blazemeter.jmeter.threads.arrivals

Class ArrivalsThreadGroup

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.arrivals.ArrivalsThreadGroup

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

Direct Known Subclasses:

FreeFormArrivalsThreadGroup

public class ArrivalsThreadGroup
extends AbstractDynamicThreadGroup

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	abandonsCount
static String	ARRIVALS_LIMIT
protected AtomicLong	arrivalsCount
protected AtomicLong	completionsCount
static String	CONCURRENCY_LIMIT
protected Set<DynamicThread>	poolThreads

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
ArrivalsThreadGroup()

Method Summary

Modifier and Type	Method and Description
void	abandonFact(org.apache.jmeter.threads.JMeterThread thread, long arrivalID)
void	addThread(DynamicThread threadWorker)
void	arrivalFact(org.apache.jmeter.threads.JMeterThread thread, long arrivalID)
boolean	canCreateMoreThreads()
void	completionFact(org.apache.jmeter.threads.JMeterThread thread, long arrivalID)
String	getArrivalsLimit()
String	getConcurrencyLimit()
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()
boolean	movedToPool(DynamicThread thread)
void	releaseAllPoolThreads()
boolean	releasedPoolThread()
void	setArrivalsLimit(String value)
void	setConcurrencyLimit(String value)
void	start(int groupIndex, org.apache.jmeter.threads.ListenerNotifier listenerNotifier, org.apache.jorphan.collections.ListedHashTree testTree, org.apache.jmeter.engine.StandardJMeterEngine engine)
void	stop() Forceful stop of test calls this
void	tellThreadsToStop() Graceful shutdown of test calls this, then #verifyThreadsStopped
void	testEnded(String s)
boolean	verifyThreadsStopped()

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

getUnit, getUnitFactor, getUnitStr, getUnitStr, isRunning, joinThreadFrom, setUnit, startNextLoop, stopThread, threadFinished, waitThreadsStopped

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

getHold, getHoldSeconds, getIterationsLimit, getIterationsLimitAsLong, getLogFilename, getNumberOfThreads, getRampUp, getRampUpSeconds, getSteps, getStepsAsLong, getTargetLevel, getTargetLevelAsDouble, getTargetLevelAsInt, getTargetLevelFactored, numberOfActiveThreads, saveLogRecord, setHold, setIterationsLimit, setLogFilename, setRampUp, setSteps, setTargetLevel, 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

CONCURRENCY_LIMIT

public static final String CONCURRENCY_LIMIT

See Also:

Constant Field Values

ARRIVALS_LIMIT

public static final String ARRIVALS_LIMIT

See Also:

Constant Field Values

arrivalsCount

protected final AtomicLong arrivalsCount

completionsCount

protected final AtomicLong completionsCount

abandonsCount

protected AtomicLong abandonsCount

poolThreads

protected final Set<DynamicThread> poolThreads

Constructor Detail

ArrivalsThreadGroup

public ArrivalsThreadGroup()

Method Detail

start

public void start(int groupIndex,
                  org.apache.jmeter.threads.ListenerNotifier listenerNotifier,
                  org.apache.jorphan.collections.ListedHashTree testTree,
                  org.apache.jmeter.engine.StandardJMeterEngine engine)

Overrides:

start in class AbstractDynamicThreadGroup

getNumThreads

public int getNumThreads()

Overrides:

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

addThread

public void addThread(DynamicThread threadWorker)

Overrides:

addThread in class AbstractDynamicThreadGroupModel

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

stop

public void stop()

Forceful stop of test calls this

Overrides:

stop in class AbstractDynamicThreadGroup

tellThreadsToStop

public void tellThreadsToStop()

Graceful shutdown of test calls this, then #verifyThreadsStopped

Overrides:

tellThreadsToStop in class AbstractDynamicThreadGroup

verifyThreadsStopped

public boolean verifyThreadsStopped()

Overrides:

verifyThreadsStopped in class AbstractDynamicThreadGroup

movedToPool

public boolean movedToPool(DynamicThread thread)

releasedPoolThread

public boolean releasedPoolThread()

isLimitReached

public boolean isLimitReached()

Specified by:

isLimitReached in class AbstractDynamicThreadGroup

arrivalFact

public void arrivalFact(org.apache.jmeter.threads.JMeterThread thread,
                        long arrivalID)

completionFact

public void completionFact(org.apache.jmeter.threads.JMeterThread thread,
                           long arrivalID)

abandonFact

public void abandonFact(org.apache.jmeter.threads.JMeterThread thread,
                        long arrivalID)

canCreateMoreThreads

public boolean canCreateMoreThreads()

setConcurrencyLimit

public void setConcurrencyLimit(String value)

getConcurrencyLimit

public String getConcurrencyLimit()

setArrivalsLimit

public void setArrivalsLimit(String value)

getArrivalsLimit

public String getArrivalsLimit()

testEnded

public void testEnded(String s)

Specified by:

testEnded in interface org.apache.jmeter.testelement.TestStateListener

Overrides:

testEnded in class AbstractDynamicThreadGroupModel

releaseAllPoolThreads

public void releaseAllPoolThreads()