Try dumping threads differently.

Author: tecarter94

deploy/tasks/buildah-oci-ta.yaml

@@ -518,7 +518,7 @@ spec:
 
           # With expansion
           cat >> /app/build-script.sh << EOF
-        for ((i=1; i<=30; i++)); do
+        for ((i=1; i<=17; i++)); do
         echo "request #$i"
         curl --max-time 30 -v -x http://localhost:8080 "http://${CACHE_HOST}/v2/cache/rebuild-central/1658389751000/org/sonatype/oss/oss-parent/7/oss-parent-7.pom"
         sleep 0.1

java-components/domain-proxy/client/src/main/java/com/redhat/hacbs/domainproxy/client/DomainProxyClient.java

@@ -52,7 +52,7 @@ public class DomainProxyClient {
     public void start() {
         Log.info("Starting domain proxy client...");
         Log.infof("Byte buffer size %d", byteBufferSize); // TODO Remove
-        executor = Executors.newCachedThreadPool();
+        executor = Executors.newVirtualThreadPerTaskExecutor();
         executor.submit(this::startClient);
     }
 
@@ -77,9 +77,7 @@ private void startClient() {
                                     .open(UnixDomainSocketAddress.of(domainSocket));
                             executor.submit(channelToChannelBiDirectionalHandler(byteBufferSize, httpClientChannel,
                                     domainSocketChannel));
-                            Log.info("Before thread dump");
                             CommonIOUtil.threadDump();
-                            Log.info("After thread dump");
                         }
                     }
                 }

java-components/domain-proxy/common/src/main/java/com/redhat/hacbs/domainproxy/common/CommonIOUtil.java

@@ -3,14 +3,12 @@
 import static java.lang.Thread.currentThread;
 
 import java.io.IOException;
-import java.lang.management.ManagementFactory;
-import java.lang.management.ThreadInfo;
-import java.lang.management.ThreadMXBean;
 import java.nio.ByteBuffer;
 import java.nio.channels.SelectionKey;
 import java.nio.channels.Selector;
 import java.nio.channels.SocketChannel;
 import java.util.Iterator;
+import java.util.Map;
 
 import org.jboss.logging.Logger;
 
@@ -164,36 +162,20 @@ private static String getChannelName(final SocketChannel channel) {
         return channelName;
     }
 
-    public static void threadDump() throws IOException {
-        // Create a timestamp with milliseconds for the file name
-        //String timestamp = new SimpleDateFormat("yyyyMMdd_HHmmss_SSS").format(new Date());
-        //String fileName = "/app/thread_dump_" + timestamp + ".txt";
-        LOG.info("Thread dump");
+    public static void threadDump() {
+        LOG.info("Before thread dump");
         String threadDumpStr = "";
-
-        // Create a PrintWriter to write the thread dump to a file
-        //try (PrintWriter writer = new PrintWriter(new FileWriter(fileName))) {
-        // Get the ThreadMXBean instance
-        ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
-
-        // Get all thread IDs
-        long[] threadIds = threadMXBean.getAllThreadIds();
-        ThreadInfo[] threadInfos = threadMXBean.getThreadInfo(threadIds, Integer.MAX_VALUE);
-
-        // Write the thread information to the file
-        for (ThreadInfo threadInfo : threadInfos) {
-            LOG.info("Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName());
-            LOG.info("Thread State: " + threadInfo.getThreadState());
-            threadDumpStr += "Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName() + "\n";
-            threadDumpStr += "Thread State: " + threadInfo.getThreadState() + "\n";
-            StackTraceElement[] stackTrace = threadInfo.getStackTrace();
-            for (StackTraceElement stackTraceElement : stackTrace) {
-                LOG.info("\t" + stackTraceElement);
-                threadDumpStr += "\t" + stackTraceElement + "\n";
+        Map<Thread, StackTraceElement[]> threadMap = Thread.getAllStackTraces();
+        for (Map.Entry<Thread, StackTraceElement[]> entry : threadMap.entrySet()) {
+            Thread thread = entry.getKey();
+            StackTraceElement[] stackTrace = entry.getValue();
+            threadDumpStr += "Thread: " + thread.getName() + " [ID: " + thread.getId() + "]\n";
+            threadDumpStr += "Thread Type: " + (thread.isVirtual() ? "Virtual" : "Platform") + "\n";
+            for (StackTraceElement ste : stackTrace) {
+                threadDumpStr += "\t" + ste + "\n";
             }
         }
-        //}
-
         LOG.info(threadDumpStr);
+        LOG.info("After thread dump");
     }
 }

java-components/domain-proxy/server/src/main/java/com/redhat/hacbs/domainproxy/server/DomainProxyServer.java

@@ -53,7 +53,7 @@ public class DomainProxyServer {
     @PostConstruct
     public void start() {
         Log.infof("Byte buffer size %d", byteBufferSize); // TODO Remove
-        executor = Executors.newCachedThreadPool();
+        executor = Executors.newVirtualThreadPerTaskExecutor();
         executor.submit(this::startServer);
     }
 
@@ -77,9 +77,7 @@ private void startServer() {
                                     .open(new InetSocketAddress(LOCALHOST, httpServerPort));
                             executor.submit(channelToChannelBiDirectionalHandler(byteBufferSize, httpServerChannel,
                                     domainSocketChannel));
-                            Log.info("Before thread dump");
                             CommonIOUtil.threadDump();
-                            Log.info("After thread dump");
                         }
                     }
                 }