IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

limit threads to cycles when threads=auto

Browse Source
This commit is contained in:
Jonathan Shook 2020-04-21 11:17:41 -05:00
parent 5c80a283a3
commit 3f51ddf0ef
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/SimpleActivity.java
View File

@ -285,7 +285,12 @@ public class SimpleActivity implements Activity {
int processors = Runtime.getRuntime().availableProcessors(); int processors = Runtime.getRuntime().availableProcessors();
if (spec.toLowerCase().equals("auto")) { if (spec.toLowerCase().equals("auto")) {
int threads = processors*10; int threads = processors*10;
logger.info("setting threads to " + threads + " (auto)"); if (threads>activityDef.getCycleCount()) {
threads=(int) activityDef.getCycleCount();
logger.info("setting threads to " + threads + " (auto) [10xCORES, cycle count limited]");
} else {
logger.info("setting threads to " + threads + " (auto) [10xCORES]");
}
activityDef.setThreads(threads); activityDef.setThreads(threads);
} else if (spec.toLowerCase().matches("\\d+x")) { } else if (spec.toLowerCase().matches("\\d+x")) {
String multiplier = spec.substring(0, spec.length() - 1); String multiplier = spec.substring(0, spec.length() - 1);
@ -296,6 +301,12 @@ public class SimpleActivity implements Activity {
logger.info("setting threads to " + spec + "(direct)"); logger.info("setting threads to " + spec + "(direct)");
activityDef.setThreads(Integer.parseInt(spec)); activityDef.setThreads(Integer.parseInt(spec));
} }
if (activityDef.getThreads()>activityDef.getCycleCount()) {
logger.warn("threads="+activityDef.getThreads() + " and cycles=" + activityDef.getCycleSummary()
+ ", you should have more cycles than threads.");
}
} else { } else {
if (cycleCount>1000) { if (cycleCount>1000) {
logger.warn("For testing at scale, it is highly recommended that you " + logger.warn("For testing at scale, it is highly recommended that you " +