fix 1129: AbstractHystrixThreadPoolAdapter set BlockingQueueCapacity

opengoofy · Mar 20, 2023 · 168252f · 168252f
1 parent 771d73f
commit 168252f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...er-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/AbstractHystrixThreadPoolAdapter.java b/...er-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/AbstractHystrixThreadPoolAdapter.java
@@ -32,6 +32,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -67,9 +68,11 @@ public ThreadPoolAdapterState getThreadPoolState(String identify) {
  ThreadPoolAdapterState result = new ThreadPoolAdapterState();
  ThreadPoolExecutor threadPoolExecutor = hystrixConsumeExecutor.get(identify);
  if (threadPoolExecutor != null) {
+ BlockingQueue<Runnable> blockingQueue = threadPoolExecutor.getQueue();
  result.setThreadPoolKey(identify);
  result.setCoreSize(threadPoolExecutor.getCorePoolSize());
  result.setMaximumSize(threadPoolExecutor.getMaximumPoolSize());
+ result.setBlockingQueueCapacity(blockingQueue.size() + blockingQueue.remainingCapacity());
  return result;
  }
  log.warn("[{}] Hystrix thread pool not found.", identify);