Shutdown resync and reflect executors now in Controller.shutdown

mindgamer · mindgamer · commit d52419cb097a · 2023-06-05T11:25:39.000-07:00
diff --git a/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java b/util/src/main/java/io/kubernetes/client/informer/cache/Controller.java
@@ -158,8 +158,8 @@ public void stop() {
         reflectorFuture.cancel(true);
       }
     }
-    reflectExecutor.shutdown();
-    resyncExecutor.shutdown();
+    reflectExecutor.shutdownNow();
+    resyncExecutor.shutdownNow();
   }
 
   /** returns true if the queue has been resycned */

Original file line number	Diff line number	Diff line change
`@@ -158,8 +158,8 @@ public void stop() {`
`158`	`158`	`reflectorFuture.cancel(true);`
`159`	`159`	`}`
`160`	`160`	`}`
`161`		`- reflectExecutor.shutdown();`
`162`		`- resyncExecutor.shutdown();`
	`161`	`+ reflectExecutor.shutdownNow();`
	`162`	`+ resyncExecutor.shutdownNow();`
`163`	`163`	`}`
`164`	`164`
`165`	`165`	`/** returns true if the queue has been resycned */`