Fix thread leakage when override controller queue with withQueue

Official Issue kubernetes-client#3738

Official PR kubernetes-client#3737

Signed-off-by: yuzhipeng <[email protected]>

Author: alaudabot

.build.yaml

@@ -0,0 +1,82 @@
+apiVersion: builds.katanomi.dev/v1alpha1
+kind: Build
+spec:
+  workspaces:
+    - description: |
+        This workspace is shared among all the pipeline tasks to read/write common resources
+      name: source
+    - name: cache
+  tasks:
+    - name: maven
+      timeout: 30m
+      retries: 0
+      taskRef:
+        resolver: katanomi.hub
+        params:
+          - name: kind
+            value: task
+          - name: name
+            value: maven
+      workspaces:
+        - name: source
+          workspace: source
+        - name: cache
+          workspace: cache
+      when: []
+      params:
+        - name: tool-image
+          value: registry.alauda.cn:60080/devops/builder-java:17.0.6-openjdk-61685958
+        - name: command
+          value: |
+            mvn versions:set -DnewVersion=11.0.0-alauda; mvn clean deploy -DskipTests
+        - name: dependencies-repositories
+          value:
+            - https://build-nexus.alauda.cn/repository/alauda-maven/
+        - name: deploy-repository
+          value: https://build-nexus.alauda.cn/repository/alauda-maven/
+  git:
+    options:
+      depth: 1
+      timeout: 10m
+      retries: 0
+      resources:
+        limits:
+          cpu: 200m
+          memory: 200Mi
+        requests:
+          cpu: 200m
+          memory: 200Mi
+  runTemplate:
+    spec:
+      workspaces:
+        - name: cache
+          persistentVolumeClaim:
+            claimName: build-cache
+          subPath: maven
+      taskRunSpecs:
+        - pipelineTaskName: maven
+          stepOverrides:
+            - name: prepare
+              resources:
+                requests:
+                  cpu: 1333m
+                  memory: 1365Mi
+                limits:
+                  cpu: 4000m
+                  memory: 4096Mi
+            - name: maven
+              resources:
+                requests:
+                  cpu: 1333m
+                  memory: 1365Mi
+                limits:
+                  cpu: 4000m
+                  memory: 4096Mi
+            - name: analysis
+              resources:
+                requests:
+                  cpu: 1334m
+                  memory: 1366Mi
+                limits:
+                  cpu: 4000m
+                  memory: 4096Mi

extended/src/main/java/io/kubernetes/client/extended/controller/builder/DefaultControllerBuilder.java

@@ -104,6 +104,9 @@ public DefaultControllerBuilder withName(String controllerName) {
    * @return the controller builder
    */
   public DefaultControllerBuilder withWorkQueue(RateLimitingQueue<Request> workQueue) {
+    if (this.workQueue != null && !this.workQueue.isShuttingDown()){
+      this.workQueue.shutDown();
+    }
     this.workQueue = workQueue;
     return this;
   }

pom.xml

@@ -17,7 +17,7 @@
     <module>client-java-contrib/cert-manager</module>
     <module>e2e</module>
     <module>client-java-contrib/prometheus-operator</module>
-    <module>examples</module>
+<!--    <module>examples</module>-->
   </modules>
 
   <scm>
@@ -323,18 +323,18 @@
     </dependencies>
   </dependencyManagement>
 
-  <distributionManagement>
-    <snapshotRepository>
-      <id>ossrh</id>
-      <url>https://oss.sonatype.org/content/repositories/snapshots</url>
-      <layout>default</layout>
-    </snapshotRepository>
-    <repository>
-      <id>ossrh</id>
-      <url>https://oss.sonatype.org/service/local/staging/deploy/maven2</url>
-      <layout>default</layout>
-    </repository>
-  </distributionManagement>
+<!--  <distributionManagement>-->
+<!--    <snapshotRepository>-->
+<!--      <id>ossrh</id>-->
+<!--      <url>https://oss.sonatype.org/content/repositories/snapshots</url>-->
+<!--      <layout>default</layout>-->
+<!--    </snapshotRepository>-->
+<!--    <repository>-->
+<!--      <id>ossrh</id>-->
+<!--      <url>https://oss.sonatype.org/service/local/staging/deploy/maven2</url>-->
+<!--      <layout>default</layout>-->
+<!--    </repository>-->
+<!--  </distributionManagement>-->
 
   <build>
     <pluginManagement>
@@ -433,16 +433,16 @@
           <skip>true</skip>
         </configuration>
       </plugin>
-      <plugin>
-        <groupId>org.sonatype.plugins</groupId>
-        <artifactId>nexus-staging-maven-plugin</artifactId>
-        <extensions>true</extensions>
-        <configuration>
-          <serverId>ossrh</serverId>
-          <nexusUrl>https://oss.sonatype.org/</nexusUrl>
-          <autoReleaseAfterClose>true</autoReleaseAfterClose>
-        </configuration>
-      </plugin>
+<!--      <plugin>-->
+<!--        <groupId>org.sonatype.plugins</groupId>-->
+<!--        <artifactId>nexus-staging-maven-plugin</artifactId>-->
+<!--        <extensions>true</extensions>-->
+<!--        <configuration>-->
+<!--          <serverId>ossrh</serverId>-->
+<!--          <nexusUrl>https://oss.sonatype.org/</nexusUrl>-->
+<!--          <autoReleaseAfterClose>true</autoReleaseAfterClose>-->
+<!--        </configuration>-->
+<!--      </plugin>-->
       <plugin>
         <groupId>com.diffplug.spotless</groupId>
         <artifactId>spotless-maven-plugin</artifactId>