p05617423
/
bench4q
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

little refa

This commit is contained in:
coderfengyun 2014-01-08 11:39:57 +08:00
parent 540ffeac25
commit b24a6585c3
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/bench4q/agent/scenario/ScenarioEngine.java
View File

@ -83,19 +83,18 @@ public class ScenarioEngine {
System.out.println("when run, classId:" + executor.toString());
this.getRunningTests().put(runId, scenarioContext);
System.out.println(poolSize);
executeTasks(executor, scenarioContext);
executeTasks(scenarioContext);
} catch (Exception e) {
e.printStackTrace();
}
}
private void executeTasks(final ExecutorService executor,
final ScenarioContext scenarioContext) {
private void executeTasks(final ScenarioContext scenarioContext) {
ExecutorService taskMaker = Executors.newSingleThreadExecutor();
taskMaker.execute(new Runnable() {
public void run() {
while (!scenarioContext.isFinished()) {
executor.execute(new Runnable() {
scenarioContext.getExecutor().execute(new Runnable() {
public void run() {
doRunScenario(scenarioContext);
logger.info("end for once!");