🔄Update: 加入拒绝策略

src/main/java/cn/hezhaohui/threadpool/conifg/AsyncConfig.java

@@ -6,6 +6,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
 
 /**
  * 异步配置类
@@ -22,6 +23,7 @@ public class AsyncConfig {
         executor.setQueueCapacity(100);
         executor.setThreadNamePrefix("Custom-Async-");
         executor.initialize();
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
         return executor;
     }
 }

src/main/java/cn/hezhaohui/threadpool/service/AsyncService.java

@@ -39,6 +39,7 @@ public class AsyncService {
             Thread.currentThread().interrupt();
         } finally {
             latch.countDown();
+            log.info("⭐ {}", latch.getCount());
         }
     }
 }

src/test/java/cn/hezhaohui/threadpool/service/AsyncServiceTest.java

@@ -18,8 +18,8 @@ class AsyncServiceTest {
 
     @Test
     void asyncPrint() throws InterruptedException {
-        CountDownLatch latch = new CountDownLatch(15);
-        for (int i = 0; i < 200; i++) {
+        CountDownLatch latch = new CountDownLatch(100);
+        for (int i = 0; i < 100; i++) {
             asyncService.asyncPrint(latch);
         }
         log.info("\n[+++ All Tasks Commited +++]\n");