=str switch to java std lib ThreadLocalRandom. (#20877)

akka-actor/src/main/scala/akka/routing/OptimalSizeExploringResizer.scala

@@ -6,7 +6,7 @@ package akka.routing
 import java.time.LocalDateTime
 
 import scala.collection.immutable
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.concurrent.duration._
 
 import com.typesafe.config.Config

akka-http-core/src/main/scala/akka/http/impl/engine/rendering/BodyPartRenderer.scala

@@ -19,7 +19,7 @@ import akka.util.ByteString
 import HttpEntity._
 import akka.stream.{ Attributes, FlowShape, Inlet, Outlet }
 
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 
 /**
  * INTERNAL API

akka-http-tests/src/test/scala/akka/http/scaladsl/coding/CoderSpec.scala

@@ -13,7 +13,7 @@ import scala.annotation.tailrec
 import scala.concurrent.duration._
 import scala.concurrent.Await
 import scala.concurrent.ExecutionContext.Implicits.global
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.util.Random
 import scala.util.control.NoStackTrace
 import org.scalatest.{ Inspectors, WordSpec }

akka-http/src/main/scala/akka/http/scaladsl/marshalling/MultipartMarshallers.scala

@@ -4,7 +4,7 @@
 
 package akka.http.scaladsl.marshalling
 
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import akka.event.{ NoLogging, LoggingAdapter }
 import akka.http.impl.engine.rendering.BodyPartRenderer
 import akka.http.scaladsl.model._

akka-stream-testkit/src/test/scala/akka/stream/testkit/ScriptedTest.scala

@@ -14,7 +14,7 @@ import org.scalatest.Matchers
 
 import scala.annotation.tailrec
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 
 trait ScriptedTest extends Matchers {
 

akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSinkSpec.scala

@@ -18,7 +18,7 @@ import akka.stream.testkit.{ GraphStageMessages, TestSinkStage }
 import akka.testkit.TestProbe
 import akka.util.ByteString
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.concurrent.{ Await, Future }
 import scala.util.control.NoStackTrace
 import akka.testkit.AkkaSpec

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowBatchSpec.scala

@@ -5,7 +5,7 @@ package akka.stream.scaladsl
 
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import akka.stream.{ OverflowStrategy, ActorMaterializer, ActorMaterializerSettings }
 import akka.stream.testkit._
 import akka.testkit.AkkaSpec

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowCollectSpec.scala

@@ -9,7 +9,7 @@ import akka.stream.impl.ConstantFun
 import akka.stream.testkit.Utils.TE
 import akka.stream.testkit.scaladsl.TestSink
 
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 
 import akka.stream.{ ActorMaterializer, ActorMaterializerSettings }
 import akka.testkit.AkkaSpec

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowConflateSpec.scala

@@ -10,7 +10,7 @@ import akka.stream.testkit.Utils.TE
 import akka.testkit.TestLatch
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import akka.stream._
 import akka.stream.testkit._
 import akka.testkit.AkkaSpec

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDropSpec.scala

@@ -3,7 +3,7 @@
  */
 package akka.stream.scaladsl
 
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 import akka.stream.ActorMaterializer
 import akka.stream.ActorMaterializerSettings
 import akka.stream.testkit._

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowExpandSpec.scala

@@ -5,7 +5,7 @@ package akka.stream.scaladsl
 
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import akka.stream.{ ActorMaterializer, ActorMaterializerSettings }
 import akka.stream.testkit._
 import akka.stream.testkit.scaladsl.TestSource

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFilterSpec.scala

@@ -5,7 +5,7 @@ package akka.stream.scaladsl
 
 import akka.stream.testkit.scaladsl.TestSink
 
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 import akka.stream.ActorAttributes._
 import akka.stream.Supervision._
 import akka.stream.testkit.Utils._

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupBySpec.scala

@@ -28,7 +28,7 @@ import akka.stream.testkit.scaladsl.TestSource
 import akka.stream.testkit.scaladsl.TestSink
 import akka.testkit.AkkaSpec
 
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 
 object FlowGroupBySpec {
 

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupedSpec.scala

@@ -4,7 +4,7 @@
 package akka.stream.scaladsl
 
 import scala.collection.immutable
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 
 import akka.stream.ActorMaterializerSettings
 import akka.testkit.AkkaSpec

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupedWithinSpec.scala

@@ -5,7 +5,7 @@ package akka.stream.scaladsl
 
 import scala.collection.immutable
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 import akka.stream.{ ActorMaterializer, ActorMaterializerSettings, ThrottleMode }
 import akka.stream.testkit._
 import akka.stream.testkit.Utils._

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapAsyncSpec.scala

@@ -6,7 +6,7 @@ package akka.stream.scaladsl
 import scala.concurrent.Await
 import scala.concurrent.Future
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.util.control.NoStackTrace
 import akka.stream.ActorMaterializer
 import akka.stream.testkit._

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapSpec.scala

@@ -3,7 +3,7 @@
  */
 package akka.stream.scaladsl
 
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 import akka.stream.ActorMaterializer
 import akka.stream.ActorMaterializerSettings
 import akka.stream.testkit._

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanSpec.scala

@@ -12,7 +12,7 @@ import akka.stream.testkit.Utils._
 import scala.collection.immutable
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 
 class FlowScanSpec extends AkkaSpec {
 

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowTakeSpec.scala

@@ -5,7 +5,7 @@ package akka.stream.scaladsl
 
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom.{ current ⇒ random }
+import java.util.concurrent.ThreadLocalRandom.{ current ⇒ random }
 import akka.stream.ActorMaterializer
 import akka.stream.ActorMaterializerSettings
 import akka.stream.actor.ActorSubscriberMessage.OnComplete

akka-stream-tests/src/test/scala/akka/stream/scaladsl/FramingSpec.scala

@@ -15,7 +15,7 @@ import akka.util.{ ByteString, ByteStringBuilder }
 import scala.collection.immutable
 import scala.concurrent.Await
 import scala.concurrent.duration._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.util.Random
 
 class FramingSpec extends AkkaSpec {

akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala

@@ -11,7 +11,7 @@ import scala.annotation.tailrec
 import scala.collection.immutable
 import akka.stream._
 import akka.stream.impl.StreamLayout._
-import scala.concurrent.forkjoin.ThreadLocalRandom
+import java.util.concurrent.ThreadLocalRandom
 import scala.util.control.NonFatal
 import java.{ util ⇒ ju }
 import akka.stream.impl.fusing.GraphStages.MaterializedValueSource