feat: attempt to figure out why thread pool is getting terminated

Author: metacosm

.github/workflows/pr.yml

@@ -15,9 +15,12 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        java: [11, 16]
-        distribution: [ temurin, adopt-openj9 ]
-        kubernetes: [ 'v1.17.13','v1.18.20','v1.19.14','v1.20.10','v1.21.4', 'v1.22.1' ]
+        #        java: [11, 16]
+        java: [ 11 ]
+        distribution: [ temurin ]
+        kubernetes: [ 'v1.22.1' ]
+    #        distribution: [ temurin, adopt-openj9 ]
+    #        kubernetes: [ 'v1.17.13','v1.18.20','v1.19.14','v1.20.10','v1.21.4', 'v1.22.1' ]
     steps:
       - uses: actions/checkout@v2
       - name: Set up Java and Maven

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ExecutorServiceProducer.java

@@ -1,17 +1,23 @@
 package io.javaoperatorsdk.operator.api.config;
 
+import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.RejectedExecutionHandler;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 
 class ExecutorServiceProducer {
 
-  private final static AtomicReference<ScheduledThreadPoolExecutor> executor =
+  private final static AtomicReference<ThreadPoolExecutor> executor =
       new AtomicReference<>();
 
   static ExecutorService getExecutor(int threadPoolSize) {
     final var gotSet =
-        executor.compareAndSet(null, new ScheduledThreadPoolExecutor(threadPoolSize));
+        executor.compareAndSet(null, new DebugThreadPoolExecutor(threadPoolSize, threadPoolSize, 0L,
+            TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>()));
     final var result = executor.get();
     if (!gotSet) {
       // check that we didn't try to change the pool size
@@ -23,4 +29,37 @@ static ExecutorService getExecutor(int threadPoolSize) {
     }
     return result;
   }
+
+  private static class DebugThreadPoolExecutor extends ThreadPoolExecutor {
+
+    public DebugThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,
+        TimeUnit unit,
+        BlockingQueue<Runnable> workQueue) {
+      super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
+    }
+
+    public DebugThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,
+        TimeUnit unit, BlockingQueue<Runnable> workQueue,
+        ThreadFactory threadFactory) {
+      super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory);
+    }
+
+    public DebugThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,
+        TimeUnit unit, BlockingQueue<Runnable> workQueue,
+        RejectedExecutionHandler handler) {
+      super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, handler);
+    }
+
+    public DebugThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,
+        TimeUnit unit, BlockingQueue<Runnable> workQueue,
+        ThreadFactory threadFactory, RejectedExecutionHandler handler) {
+      super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
+    }
+
+    @Override
+    public void shutdown() {
+      Thread.dumpStack();
+      super.shutdown();
+    }
+  }
 }