diff --git a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java index 65f869c2f4..9a5c9351ec 100644 --- a/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java +++ b/core-java/src/main/java/com/baeldung/concurrent/blockingqueue/NumbersProducer.java @@ -1,12 +1,11 @@ package com.baeldung.concurrent.blockingqueue; -import java.util.Random; import java.util.concurrent.BlockingQueue; +import java.util.concurrent.ThreadLocalRandom; class NumbersProducer implements Runnable { - private final Random random = new Random(); private final BlockingQueue numbersQueue; private final int poisonPill; private final int poisonPillPerProducer; @@ -29,7 +28,7 @@ class NumbersProducer implements Runnable { private void generateNumbers() throws InterruptedException { for (int i = 0; i < 100; i++) { - numbersQueue.put(random.nextInt(100)); + numbersQueue.put(ThreadLocalRandom.current().nextInt(100)); } for (int j = 0; j < poisonPillPerProducer; j++) { numbersQueue.put(poisonPill);