Fix metric PotentialMaxThreadCount (ydb-platform#629)

Co-authored-by: Aleksandr Kriukov <kruall@ydb.ru>
marsaly79 · Dec 22, 2023 · de89cc6 · de89cc6
1 parent 2208cdd
commit de89cc6
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/ydb/library/actors/core/harmonizer.cpp b/ydb/library/actors/core/harmonizer.cpp
@@ -467,10 +467,6 @@ void THarmonizer::HarmonizeImpl(ui64 ts) {
     if (budget < -0.1) {
         isStarvedPresent = true;
     }
-    for (size_t poolIdx = 0; poolIdx < Pools.size(); ++poolIdx) {
-        TPoolInfo& pool = Pools[poolIdx];
-        AtomicSet(pool.PotentialMaxThreadCount, Min(pool.MaxThreadCount, budgetInt));
-    }
     double overbooked = consumed - booked;
     if (overbooked < 0) {
         isStarvedPresent = false;
@@ -591,6 +587,11 @@ void THarmonizer::HarmonizeImpl(ui64 ts) {
             pool.SetThreadCount(threadCount - 1);
         }
     }
+
+    for (size_t poolIdx = 0; poolIdx < Pools.size(); ++poolIdx) {
+        TPoolInfo& pool = Pools[poolIdx];
+        AtomicSet(pool.PotentialMaxThreadCount, std::min<i64>(pool.MaxThreadCount, pool.GetThreadCount() + budgetInt));
+    }
 }
 
 void THarmonizer::CalculatePriorityOrder() {