[FLINK-36208][core] Use ThreadLocalRandom in AbstractID

AHeise · Sep 17, 2024 · 96b8425 · 96b8425
1 parent 6cb9cb5
commit 96b8425
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/util/AbstractID.java b/flink-core/src/main/java/org/apache/flink/util/AbstractID.java
@@ -20,16 +20,14 @@
 
 import org.apache.flink.annotation.PublicEvolving;
 
-import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
 
 /** A statistically unique identification number. */
 @PublicEvolving
 public class AbstractID implements Comparable<AbstractID>, java.io.Serializable {
 
     private static final long serialVersionUID = 1L;
 
-    private static final Random RND = new Random();
-
     /** The size of a long in bytes. */
     private static final int SIZE_OF_LONG = 8;
 
@@ -86,8 +84,9 @@ public AbstractID(AbstractID id) {
 
     /** Constructs a new random ID from a uniform distribution. */
     public AbstractID() {
-        this.lowerPart = RND.nextLong();
-        this.upperPart = RND.nextLong();
+        ThreadLocalRandom random = ThreadLocalRandom.current();
+        this.lowerPart = random.nextLong();
+        this.upperPart = random.nextLong();
     }
 
     // --------------------------------------------------------------------------------------------