aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-11-04 13:00:37 +0100
committerGitHub <noreply@github.com>2022-11-04 13:00:37 +0100
commit419f93800baa0fdd6e9260f8a9485bb0f2322f0a (patch)
tree7643a4b9d18bcf9f2e5cba621d7002e1cd19a0e4
parentaf6f5935e83224fc89fd0be63bde4d2166ada0bc (diff)
parentbf781c39fef476a6db3b0ad5ef46f7fffe0c4d5d (diff)
Merge pull request #24746 from vespa-engine/jonmv/use-threadlocal-random
Use thread-local random
-rw-r--r--vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java
index 58afac885eb..43a16c2abf0 100644
--- a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java
+++ b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java
@@ -31,6 +31,7 @@ import java.util.Map;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
@@ -243,7 +244,7 @@ public class CliClient {
/** Creates an input stream that spits out random documents (id and data) for one minute. */
static InputStream createDummyInputStream(int payloadSize) {
Instant end = Instant.now().plusSeconds(60);
- return createDummyInputStream(payloadSize, new Random(), () -> Instant.now().isBefore(end));
+ return createDummyInputStream(payloadSize, ThreadLocalRandom.current(), () -> Instant.now().isBefore(end));
}
static InputStream createDummyInputStream(int payloadSize, Random random, BooleanSupplier hasNext) {