Attempt to debug CI flaky timeout. DO NOT MERGE!

Author: AlexeyKuznetsov-DD

dd-java-agent/instrumentation/java-concurrent/java-concurrent-21/src/previewTest/groovy/StructuredConcurrencyTest.groovy

@@ -2,13 +2,39 @@ import datadog.trace.agent.test.AgentTestRunner
 import datadog.trace.api.Trace
 
 import java.util.concurrent.Callable
+import java.util.concurrent.Executors
+import java.util.concurrent.ScheduledExecutorService
+import java.util.concurrent.ScheduledFuture
 import java.util.concurrent.StructuredTaskScope
+import java.util.concurrent.TimeUnit
 
 import static datadog.trace.agent.test.utils.TraceUtils.runUnderTrace
 import static datadog.trace.agent.test.utils.TraceUtils.runnableUnderTrace
 import static java.time.Instant.now
 
 class StructuredConcurrencyTest extends AgentTestRunner {
+  ScheduledExecutorService scheduler
+  ScheduledFuture<?> threadDumpTask
+
+  def setup() {
+    scheduler = Executors.newSingleThreadScheduledExecutor()
+
+    threadDumpTask = scheduler.schedule({
+      println "=== Thread Dump Triggered at ${new Date()} ==="
+      Thread.getAllStackTraces().each { thread, stack ->
+        println "Thread: ${thread.name}, daemon: ${thread.daemon}"
+        stack.each { println "\tat ${it}" }
+      }
+      println "==============================================="
+    }, 7, TimeUnit.MINUTES)
+  }
+
+  def cleanup() {
+    threadDumpTask?.cancel(false)
+    scheduler?.shutdownNow()
+  }
+
+
   /**
    * Tests the structured task scope with a single task.
    */

dd-java-agent/instrumentation/lettuce-4/src/test/groovy/Lettuce4ClientTestBase.groovy

@@ -8,6 +8,11 @@ import datadog.trace.agent.test.utils.PortUtils
 import redis.embedded.RedisServer
 import spock.lang.Shared
 
+import java.util.concurrent.Executors
+import java.util.concurrent.ScheduledExecutorService
+import java.util.concurrent.ScheduledFuture
+import java.util.concurrent.TimeUnit
+
 import static datadog.trace.agent.test.utils.TraceUtils.runUnderTrace
 
 abstract class Lettuce4ClientTestBase extends VersionedNamingTestBase {
@@ -32,6 +37,9 @@ abstract class Lettuce4ClientTestBase extends VersionedNamingTestBase {
   @Shared
   RedisServer redisServer
 
+  ScheduledExecutorService scheduler
+  ScheduledFuture<?> threadDumpTask
+
   @Shared
   Map<String, String> testHashMap = [
     firstname: "John",
@@ -61,6 +69,18 @@ abstract class Lettuce4ClientTestBase extends VersionedNamingTestBase {
   }
 
   def setup() {
+    scheduler = Executors.newSingleThreadScheduledExecutor()
+
+    threadDumpTask = scheduler.schedule({
+      println "=== Thread Dump Triggered at ${new Date()} ==="
+      Thread.getAllStackTraces().each { thread, stack ->
+        println "Thread: ${thread.name}, daemon: ${thread.daemon}"
+        stack.each { println "\tat ${it}" }
+      }
+      println "==============================================="
+    }, 7, TimeUnit.MINUTES)
+
+
     redisServer.start()
 
     redisClient = RedisClient.create(embeddedDbUri)
@@ -79,6 +99,9 @@ abstract class Lettuce4ClientTestBase extends VersionedNamingTestBase {
   }
 
   def cleanup() {
+    threadDumpTask?.cancel(false)
+    scheduler?.shutdownNow()
+
     connection.close()
     redisClient.shutdown()
     redisServer.stop()