From 1e3d980437a0daf2269d753afa90ceb9ad7a4b43 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 15 Jan 2021 15:07:30 +0800
Subject: [PATCH]

---
 src/org/redkale/util/ThreadHashExecutor.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/org/redkale/util/ThreadHashExecutor.java b/src/org/redkale/util/ThreadHashExecutor.java
index d34adfa75..ea0fd6806 100644
--- a/src/org/redkale/util/ThreadHashExecutor.java
+++ b/src/org/redkale/util/ThreadHashExecutor.java
@@ -63,6 +63,14 @@ public class ThreadHashExecutor {
         }
     }
 
+    public int waitingSize() {
+        int wsize = queues[0].size();
+        for (int i = 1; i < queues.length; i++) {
+            wsize += queues[i].size();
+        }
+        return wsize;
+    }
+
     public void shutdown() {
         for (ExecutorService executor : this.executors) {
             executor.shutdown();