From f74e3e66f1336cb68e582cb91f9d38c397f85a37 Mon Sep 17 00:00:00 2001
From: Eugene Yokota <eed3si9n@gmail.com>
Date: Thu, 24 Aug 2017 17:51:50 -0400
Subject: [PATCH] Trying to reproduce sbt/util#119

---
 .../src/test/scala/ManagedLoggerSpec.scala    | 24 +++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/internal/util-logging/src/test/scala/ManagedLoggerSpec.scala b/internal/util-logging/src/test/scala/ManagedLoggerSpec.scala
index a0cf1e569..40601f1c4 100644
--- a/internal/util-logging/src/test/scala/ManagedLoggerSpec.scala
+++ b/internal/util-logging/src/test/scala/ManagedLoggerSpec.scala
@@ -50,6 +50,30 @@ class ManagedLoggerSpec extends FlatSpec with Matchers {
     log.infoEvent(Vector(Vector(1, 2, 3)))
   }
 
+  it should "be thread safe" in {
+    import java.util.concurrent.{ Executors, TimeUnit }
+    import sjsonnew.BasicJsonProtocol._
+    val pool = Executors.newFixedThreadPool(100)
+
+    for {
+      i <- 1 to 10000
+    } {
+      pool.submit(new Runnable {
+        def run(): Unit = {
+          val stringTypeTag = StringTypeTag[List[Int]]
+          val log = LogExchange.logger(s"foo$i")
+          LogExchange.bindLoggerAppenders(s"foo$i", List(LogExchange.asyncStdout -> Level.Info))
+          if (i % 100 == 0) {
+            log.info(s"foo$i test $stringTypeTag")
+          }
+          Thread.sleep(1)
+        }
+      })
+    }
+    pool.shutdown
+    pool.awaitTermination(30, TimeUnit.SECONDS)
+  }
+
   "global logging" should "log immediately after initialization" in {
     // this is passed into State normally
     val global0 = initialGlobalLogging