naming Threads

Author: csviri

operator-framework/src/main/java/io/javaoperatorsdk/operator/Operator.java

@@ -41,7 +41,7 @@ public <R extends CustomResource> void registerControllerForAllNamespaces(Resour
         registerController(controller, true);
     }
 
-    public <R extends CustomResource> void registerController(ResourceController<R> controller,  String... targetNamespaces) throws OperatorException {
+    public <R extends CustomResource> void registerController(ResourceController<R> controller, String... targetNamespaces) throws OperatorException {
         registerController(controller, false, targetNamespaces);
     }
 
@@ -58,7 +58,7 @@ private <R extends CustomResource> void registerController(ResourceController<R>
 
 
         ResourceCache resourceCache = new ResourceCache();
-        DefaultEventHandler defaultEventHandler = new DefaultEventHandler(resourceCache, eventDispatcher);
+        DefaultEventHandler defaultEventHandler = new DefaultEventHandler(resourceCache, eventDispatcher, controller.getClass().getName());
         DefaultEventSourceManager eventSourceManager = new DefaultEventSourceManager(defaultEventHandler);
         defaultEventHandler.setDefaultEventSourceManager(eventSourceManager);
 

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/DefaultEventHandler.java

@@ -9,6 +9,7 @@
 import java.util.HashSet;
 import java.util.Set;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.locks.ReentrantLock;
 
 import static io.javaoperatorsdk.operator.processing.ProcessingUtils.containsCustomResourceDeletedEvent;
@@ -31,11 +32,16 @@ public class DefaultEventHandler implements EventHandler {
 
     private final ReentrantLock lock = new ReentrantLock();
 
-    public DefaultEventHandler(ResourceCache resourceCache, EventDispatcher eventDispatcher) {
+    public DefaultEventHandler(ResourceCache resourceCache, EventDispatcher eventDispatcher, String relatedControllerName) {
         this.resourceCache = resourceCache;
         this.eventDispatcher = eventDispatcher;
         eventBuffer = new EventBuffer();
-        executor = new ScheduledThreadPoolExecutor(5);
+        executor = new ScheduledThreadPoolExecutor(5, new ThreadFactory() {
+            @Override
+            public Thread newThread(Runnable runnable) {
+                return new Thread(runnable, "EventHandler-" + relatedControllerName);
+            }
+        });
     }
 
     public void setDefaultEventSourceManager(DefaultEventSourceManager defaultEventSourceManager) {

operator-framework/src/test/java/io/javaoperatorsdk/operator/processing/DefaultEventHandlerTest.java

@@ -24,7 +24,7 @@ class DefaultEventHandlerTest {
     public static final int SEPARATE_EXECUTION_TIMEOUT = 450;
     private EventDispatcher eventDispatcherMock = mock(EventDispatcher.class);
     private ResourceCache resourceCache = new ResourceCache();
-    private DefaultEventHandler defaultEventHandler = new DefaultEventHandler(resourceCache, eventDispatcherMock);
+    private DefaultEventHandler defaultEventHandler = new DefaultEventHandler(resourceCache, eventDispatcherMock, "Test");
     private DefaultEventSourceManager defaultEventSourceManagerMock = mock(DefaultEventSourceManager.class);
 
     @BeforeEach