One more try

Author: AlexeyKuznetsov-DD

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

@@ -17,36 +17,34 @@ class StructuredConcurrencyTest extends AgentTestRunner {
   ScheduledFuture<?> threadDumpTask
 
   def setup() {
-    scheduler = Executors.newSingleThreadScheduledExecutor()
+    File reportDir = new File("build")
+    String fullPath = reportDir.absolutePath.replace("dd-trace-java/dd-java-agent",
+    "dd-trace-java/workspace/dd-java-agent")
+
+    reportDir = new File(fullPath)
+    if (!reportDir.exists()) {
+      println("Folder not found: " + fullPath)
+      reportDir.mkdirs()
+    }
+    else println("Folder found: " + fullPath)
 
+    scheduler = Executors.newSingleThreadScheduledExecutor()
     threadDumpTask = scheduler.scheduleAtFixedRate({
-      File reportDir = new File("build")
-      String fullPath = reportDir.absolutePath.replace("dd-trace-java/dd-java-agent",
-      "dd-trace-java/workspace/dd-java-agent")
-
-      reportDir = new File(fullPath)
-      if (!reportDir.exists()) {
-        println("Folder not found: " + fullPath)
-        reportDir.mkdirs()
-      }
-
       // Define the file path
       File reportFile = new File(fullPath, String.format("thread-dump-%d.log", System.currentTimeMillis()))
 
       // Write to the file
       try (FileWriter writer = new FileWriter(reportFile)) {
-        println(s)
         writer.write("=== Thread Dump Triggered at ${new Date()} ===\n")
         Thread.getAllStackTraces().each { thread, stack ->
-          println(t)
           writer.write("Thread: ${thread.name}, daemon: ${thread.daemon}\n")
           stack.each {
             writer.write("\tat ${it}\n")
           }
         }
         writer.write("==============================================\n")
       }
-    }, 60_000, 60_000, TimeUnit.MILLISECONDS)
+    }, 10, 60_000, TimeUnit.MILLISECONDS)
   }
 
   def cleanup() {

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

@@ -69,36 +69,34 @@ abstract class Lettuce4ClientTestBase extends VersionedNamingTestBase {
   }
 
   def setup() {
-    scheduler = Executors.newSingleThreadScheduledExecutor()
+    File reportDir = new File("build")
+    String fullPath = reportDir.absolutePath.replace("dd-trace-java/dd-java-agent",
+    "dd-trace-java/workspace/dd-java-agent")
+
+    reportDir = new File(fullPath)
+    if (!reportDir.exists()) {
+      println("Folder not found: " + fullPath)
+      reportDir.mkdirs()
+    }
+    else println("Folder found: " + fullPath)
 
+    scheduler = Executors.newSingleThreadScheduledExecutor()
     threadDumpTask = scheduler.scheduleAtFixedRate({
-      File reportDir = new File("build")
-      String fullPath = reportDir.absolutePath.replace("dd-trace-java/dd-java-agent",
-      "dd-trace-java/workspace/dd-java-agent")
-
-      reportDir = new File(fullPath)
-      if (!reportDir.exists()) {
-        println("Folder not found: " + fullPath)
-        reportDir.mkdirs()
-      }
-
       // Define the file path
       File reportFile = new File(fullPath, String.format("thread-dump-%d.log", System.currentTimeMillis()))
 
       // Write to the file
       try (FileWriter writer = new FileWriter(reportFile)) {
-        println(s)
         writer.write("=== Thread Dump Triggered at ${new Date()} ===\n")
         Thread.getAllStackTraces().each { thread, stack ->
-          println(t)
           writer.write("Thread: ${thread.name}, daemon: ${thread.daemon}\n")
           stack.each {
             writer.write("\tat ${it}\n")
           }
         }
         writer.write("==============================================\n")
       }
-    }, 60_000, 60_000, TimeUnit.MILLISECONDS)
+    }, 10, 60_000, TimeUnit.MILLISECONDS)
 
     redisServer.start()