本文整理了Java中org.apache.jmeter.threads.JMeterContextService
类的一些代码示例,展示了JMeterContextService
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JMeterContextService
类的具体详情如下:
包路径:org.apache.jmeter.threads.JMeterContextService
类名称:JMeterContextService
[英]Provides context service for JMeter threads. Keeps track of active and total thread counts.
[中]为JMeter线程提供上下文服务。跟踪活动线程数和总线程数。
代码示例来源:origin: undera/jmeter-plugins
@Override
public void sampleOccurred(SampleEvent event) {
// just dropping regular test samples
// update JMeterContext for share with samplers thread in order to provide
// updated variables
this.ctx = JMeterContextService.getContext();
}
代码示例来源:origin: Blazemeter/jmeter-bzm-plugins
public static void decrNumberOfThreads() {
JMeterContextService.decrNumberOfThreads();
}
代码示例来源:origin: Blazemeter/jmeter-bzm-plugins
public static void incrNumberOfThreads() {
JMeterContextService.incrNumberOfThreads();
}
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
@Override
public JMeterThread addNewThread(int delay, StandardJMeterEngine engine) {
long now = System.currentTimeMillis();
JMeterContext context = JMeterContextService.getContext();
JMeterThread newJmThread;
int numThreads;
synchronized (addThreadLock) {
numThreads = getNumThreads();
setNumThreads(numThreads + 1);
}
newJmThread = startNewThread(notifier, threadGroupTree, engine, numThreads, context, now, delay);
JMeterContextService.addTotalThreads( 1 );
log.info("Started new thread in group {}", groupNumber);
return newJmThread;
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
@Override
public void threadFinished() {
JMeterContextService.decrNumberOfThreads();
GuiPackage gp =GuiPackage.getInstance();
if (gp != null) {// check there is a GUI
gp.getMainFrame().updateCounts();
}
for (RemoteThreadsLifeCycleListener listener : listeners) {
listener.threadNumberDecreased(JMeterContextService.getNumberOfThreads());
}
}
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
/**
*
* @see RemoteThreadsListener#threadStarted()
*/
@Override
public void threadStarted() {
JMeterContextService.incrNumberOfThreads();
GuiPackage gp =GuiPackage.getInstance();
if (gp != null) {// check there is a GUI
gp.getMainFrame().updateCounts();
}
for (RemoteThreadsLifeCycleListener listener : listeners) {
listener.threadNumberIncreased(JMeterContextService.getNumberOfThreads());
}
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
/**
* @return true if test is running
*/
public static boolean isTestRunning() {
return JMeterContextService.getTestStartTime()>0;
}
代码示例来源:origin: undera/jmeter-plugins
@Override
public void addThread(DynamicThread threadWorker) {
super.addThread(threadWorker);
JMeterContextService.addTotalThreads(1);
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
protected void computeTestDuration(ActionEvent evt) {
long startTime = JMeterContextService.getTestStartTime();
if (startTime > 0) {
long elapsedSec = (System.currentTimeMillis() - startTime + 500) / 1000; // rounded seconds
testTimeDuration.setText(JOrphanUtils.formatDuration(elapsedSec));
}
}
代码示例来源:origin: kg.apc/jmeter-plugins-standard
@Override
public void addThread(DynamicThread threadWorker) {
super.addThread(threadWorker);
JMeterContextService.addTotalThreads(1);
}
代码示例来源:origin: undera/jmeter-plugins
@Override
public void sampleOccurred(SampleEvent event) {
// just dropping regular test samples
// update JMeterContext for share with samplers thread in order to provide
// updated variables
this.ctx = JMeterContextService.getContext();
}
代码示例来源:origin: undera/jmeter-plugins
public static void incrNumberOfThreads() {
JMeterContextService.incrNumberOfThreads();
refreshUI();
}
代码示例来源:origin: undera/jmeter-plugins
public static void decrNumberOfThreads() {
JMeterContextService.decrNumberOfThreads();
refreshUI();
}
代码示例来源:origin: delirius325/jmeter-elasticsearch-backend-listener
String sElapsed;
long start = JMeterContextService.getTestStartTime();
long end = System.currentTimeMillis();
long elapsed = (end - start);
代码示例来源:origin: kg.apc/jmeter-plugins-casutg
@Override
public void addThread(DynamicThread threadWorker) {
super.addThread(threadWorker);
JMeterContextService.addTotalThreads(1);
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_java
/**
*
* @return {@link JMeterContext}
*/
public JMeterContext getJMeterContext() {
return JMeterContextService.getContext();
}
/**
代码示例来源:origin: kg.apc/jmeter-plugins-casutg
public static void incrNumberOfThreads() {
JMeterContextService.incrNumberOfThreads();
refreshUI();
}
代码示例来源:origin: kg.apc/jmeter-plugins-standard
public static void decrNumberOfThreads() {
JMeterContextService.decrNumberOfThreads();
refreshUI();
}
代码示例来源:origin: undera/jmeter-plugins
@Override
public void add(SampleResult sample) {
if (relativeStartTime == 0) {
//
if(!isIgnoreCurrentTestStartTime()){
relativeStartTime = JMeterContextService.getTestStartTime();
}
isJtlLoad = false;
if (relativeStartTime == 0) {
relativeStartTime = sample.getStartTime();
isJtlLoad = true;
}
relativeStartTime = relativeStartTime - relativeStartTime%getGranulation();
handleRelativeStartTime();
}
if(isJtlLoad) {
if(relativeStartTime > sample.getStartTime()) {
relativeStartTime = sample.getStartTime() - sample.getStartTime()%getGranulation();
handleRelativeStartTime();
}
}
}
代码示例来源:origin: org.apache.jmeter/ApacheJMeter_core
JMeterContextService.addTotalThreads(numThreads);
boolean onErrorStopTest = group.getOnErrorStopTest();
boolean onErrorStopTestNow = group.getOnErrorStopTestNow();
内容来源于网络,如有侵权,请联系作者删除!