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

binding improvements

Browse Source
This commit is contained in:
Jonathan Shook 2025-01-02 12:14:18 -06:00
parent f249d49f26
commit 548bdd0e98
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nb-virtdata/virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/nondeterministic/to_long/ThreadNum.java
View File

@ -29,6 +29,8 @@ import java.util.regex.Pattern;
@Categories({Category.state})
public class ThreadNum implements LongUnaryOperator {
private final long defaultValue;
private static final Pattern pattern = Pattern.compile("^.*?(\\d+).*$");
private final transient ThreadLocal<Long> threadLocalInt = new ThreadLocal<Long>() {
@Override
@ -41,13 +43,17 @@ public class ThreadNum implements LongUnaryOperator {
if (matcher.matches()) {
return Long.valueOf(matcher.group(1));
} else {
throw new RuntimeException(
"Unable to match a digit sequence in thread name:" + Thread.currentThread().getName()
);
return defaultValue;
}
}
};
public ThreadNum() {
this(-1L);
}
public ThreadNum(long defaultValue) {
this.defaultValue = defaultValue;
}
@Override
public long applyAsLong(long input) {
return threadLocalInt.get();