From cd543cad944cd3578718a4f61aba64f56a329f36 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@warp.ovh>
Date: Tue, 26 May 2020 12:51:08 +0200
Subject: [PATCH] Update BoundedExecutorServiceImpl.java

---
 .../tdlib/utils/BoundedExecutorServiceImpl.java        | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/main/java/it/ernytech/tdlib/utils/BoundedExecutorServiceImpl.java b/src/main/java/it/ernytech/tdlib/utils/BoundedExecutorServiceImpl.java
index 68d42ec..09efe04 100644
--- a/src/main/java/it/ernytech/tdlib/utils/BoundedExecutorServiceImpl.java
+++ b/src/main/java/it/ernytech/tdlib/utils/BoundedExecutorServiceImpl.java
@@ -64,14 +64,16 @@ class BoundedExecutorServiceImpl extends ThreadPoolExecutor implements BoundedEx
 			}
 		}
 		semaphore.acquire();
-		var queueSize = getQueue().size();
-		synchronized (queueSizeStatusLock) {
-			if (queueSizeStatus != null) queueSizeStatus.accept(queueSize >= maxQueueSize, queueSize);
-		}
 	}
 
 	@Override
 	public void beforeExecute(Thread t, Runnable r) {
+
+		var queueSize = getQueue().size();
+		synchronized (queueSizeStatusLock) {
+			if (queueSizeStatus != null) queueSizeStatus.accept(queueSize >= maxQueueSize, queueSize);
+		}
+
 		semaphore.release();
 
 		super.beforeExecute(t, r);