Use ConcurrentHashtable for telemetry log deduplication

internal-api/src/jmh/java/datadog/trace/api/telemetry/LogCollectorBenchmark.java

@@ -2,7 +2,11 @@
 
 import org.openjdk.jmh.annotations.Benchmark;
 import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Level;
 import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.Threads;
 import org.openjdk.jmh.annotations.Warmup;
 
@@ -11,34 +15,44 @@
 @Measurement(iterations = 5)
 @Threads(8)
 public class LogCollectorBenchmark {
+  @State(Scope.Benchmark)
+  public static class CollectorState {
+    final LogCollector collector = new LogCollector(4);
+
+    @Setup(Level.Trial)
+    public void setup() {
+      collector.addLogMessage("error", "ugh!", null);
+    }
+  }
+
   @Benchmark
-  public void noException_before() {
-    LogCollector.get().addLogMessage("error", "ugh!", null);
+  public void duplicateWithoutException(CollectorState state) {
+    state.collector.addLogMessage("error", "ugh!", null);
   }
 
   static final Object NULL = null;
 
   @Benchmark
-  public void nullPointerException() {
+  public void nullPointerException(CollectorState state) {
     // Represents the fast throw case where the JVM switches to using
     // a single Exception instance to handle a hot throw location
     // of NullPointerException, ArrayIndexOutOfBoundsException, etc.
     // In this case, the stacktrace of the exception will not be available.
     try {
       NULL.hashCode();
     } catch (Throwable t) {
-      LogCollector.get().addLogMessage("error", "npe", t);
+      state.collector.addLogMessage("error", "npe", t);
     }
   }
 
   @Benchmark
-  public void unsupportedOperationException() {
+  public void unsupportedOperationException(CollectorState state) {
     // Represents the common case where stack trace is preserved
     // despite hot throw
     try {
       unsupportedOperation();
     } catch (Throwable t) {
-      LogCollector.get().addLogMessage("error", "unsupported", t);
+      state.collector.addLogMessage("error", "unsupported", t);
     }
   }