Add try...catch.. for processTaskQueue

hazelcast · Apr 12, 2024 · 8d021c5 · 8d021c5
1 parent 49cde4f
commit 8d021c5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java b/hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java
@@ -352,7 +352,11 @@ private boolean processTaskQueue() {
             if (task == null) {
                 break;
             }
-            task.run();
+            try {
+                task.run();
+            } catch (Exception e) {
+                logger.warning("Task run exception", e);
+            }
             completedTaskCount.inc();
             tasksProcessed = true;
         }