diff options
author | jonmv <venstad@gmail.com> | 2022-11-04 12:41:55 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-11-04 12:41:55 +0100 |
commit | bf781c39fef476a6db3b0ad5ef46f7fffe0c4d5d (patch) | |
tree | 74d7dd4d1aa3a80c1d62d7f9dfe3f899ac7951d7 /vespa-feed-client-cli | |
parent | 6e4f35a57868275f15df5136eebcae20d231b280 (diff) |
Use thread-local random
Diffstat (limited to 'vespa-feed-client-cli')
-rw-r--r-- | vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/impl/CliClient.java | 3 |
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) { |