org.apache.jmeter.threads.JMeterContextService类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(175)

本文整理了Java中org.apache.jmeter.threads.JMeterContextService类的一些代码示例,展示了JMeterContextService类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JMeterContextService类的具体详情如下:
包路径:org.apache.jmeter.threads.JMeterContextService
类名称: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();

相关文章