parallel test on

Author: j5ik2o

build.sbt

@@ -46,16 +46,16 @@ lazy val baseSettings = Seq(
   semanticdbVersion := scalafixSemanticdb.revision,
   Test / publishArtifact := false,
   Test / fork := true
-//  testForkedParallel := true,
-//  concurrentRestrictions := {
-//    val par = parallelExecution.value
-//    val max = EvaluateTask.SystemProcessors
-//    List(
-//      Tags.limitAll(if (par) max else 1),
-//      Tags.limit(Tags.ForkedTestGroup, 2),
-//      Tags.exclusiveGroup(Tags.Clean)
-//    )
-//  }
+  testForkedParallel := true,
+  concurrentRestrictions := {
+    val par = parallelExecution.value
+    val max = EvaluateTask.SystemProcessors
+    List(
+      Tags.limitAll(if (par) max else 1),
+      Tags.limit(Tags.ForkedTestGroup, 2),
+      Tags.exclusiveGroup(Tags.Clean)
+    )
+  }
 )
 
 val `docker-controller-scala-core` = (project in file("docker-controller-scala-core"))

docker-controller-scala-core/src/main/scala/com/github/j5ik2o/dockerController/RandomPortUtil.scala

@@ -5,7 +5,7 @@ import java.nio.channels.ServerSocketChannel
 
 trait RandomPortUtil {
 
-  def temporaryServerAddress(interface: String = "127.0.0.1"): InetSocketAddress = {
+  def temporaryServerAddress(interface: String = "127.0.0.1"): InetSocketAddress = synchronized {
     val serverSocket = ServerSocketChannel.open()
     try {
       serverSocket.socket.bind(new InetSocketAddress(interface, 0))
@@ -14,7 +14,7 @@ trait RandomPortUtil {
     } finally serverSocket.close()
   }
 
-  def temporaryServerHostnameAndPort(interface: String = "127.0.0.1"): (String, Int) = {
+  def temporaryServerHostnameAndPort(interface: String = "127.0.0.1"): (String, Int) = synchronized {
     val socketAddress = temporaryServerAddress(interface)
     socketAddress.getHostName -> socketAddress.getPort
   }