Fix test bug in CacheTests#testDependentKeyDeadlock
This commit is contained in:
parent
813f494f12
commit
1390e68465
|
@ -542,7 +542,14 @@ public class CacheTests extends ESTestCase {
|
||||||
for (int j = 0; j < numberOfEntries; j++) {
|
for (int j = 0; j < numberOfEntries; j++) {
|
||||||
Key key = new Key(random.nextInt(numberOfEntries));
|
Key key = new Key(random.nextInt(numberOfEntries));
|
||||||
try {
|
try {
|
||||||
cache.computeIfAbsent(key, k -> k.key != 0 ? cache.get(new Key(k.key / 2)) : 0);
|
cache.computeIfAbsent(key, k -> {
|
||||||
|
if (k.key == 0) {
|
||||||
|
return 0;
|
||||||
|
} else {
|
||||||
|
Integer value = cache.get(new Key(k.key / 2));
|
||||||
|
return value != null ? value : 0;
|
||||||
|
}
|
||||||
|
});
|
||||||
} catch (ExecutionException e) {
|
} catch (ExecutionException e) {
|
||||||
fail(e.getMessage());
|
fail(e.getMessage());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue