fixed the scheduler to show real time threads active

Author: arcenox

src/TickerQ/Src/SoftSchedulerNotifyDebounce.cs

@@ -21,7 +21,8 @@ public SoftSchedulerNotifyDebounce(Action<string> notifyCoreAction)
         }
 
         /// <summary>
-        /// Debounces notifications; fires immediately when count == 0, otherwise after Debounce.
+        /// Sends notifications in a thread-safe way and suppresses duplicates.
+        /// Fires immediately for every change.
         /// </summary>
         internal void NotifySafely(int count)
         {
@@ -30,16 +31,8 @@ internal void NotifySafely(int count)
             if (Volatile.Read(ref _disposed) == 1)
                 return;
 
-            var due = (count == 0) ? TimeSpan.Zero : Debounce;
-
-            try
-            {
-                _timer.Change(due, Timeout.InfiniteTimeSpan);
-            }
-            catch (ObjectDisposedException)
-            {
-                // Raced with Dispose(); ignore.
-            }
+            // Call immediately so the reported thread count stays in sync
+            Callback(null);
         }
 
         /// <summary>
@@ -75,4 +68,4 @@ public void Dispose()
             _timer.Dispose();
         }
     }
-}
+}

src/TickerQ/Src/TickerQThreadPool/TickerQTaskScheduler.cs

@@ -53,11 +53,8 @@ public TickerQTaskScheduler(
             _workerQueues[i] = new ConcurrentQueue<WorkItem>();
         }
 
-        // Start all workers upfront to honor maxConcurrency
-        for (int i = 0; i < _maxConcurrency; i++)
-        {
-            TryStartWorker();
-        }
+        // Start at least one worker immediately to handle incoming tasks
+        TryStartWorker();
     }
 
     /// <summary>
@@ -250,7 +247,24 @@ private async Task WorkerLoopCoreAsync(int workerId)
                 // No work found - check if we should exit
                 if (DateTime.UtcNow - lastWorkTime > _idleWorkerTimeout)
                 {
-                    // Keep workers alive to maintain maxConcurrency; just reset timer
+                    // Check ALL queues for any remaining work before exiting
+                    bool anyWorkRemaining = false;
+                    for (int i = 0; i < _maxConcurrency; i++)
+                    {
+                        if (_workerQueues[i].Count > 0)
+                        {
+                            anyWorkRemaining = true;
+                            break;
+                        }
+                    }
+                    
+                    // Only exit if there's really no work and we have minimum workers
+                    if (!anyWorkRemaining && _totalQueuedTasks == 0 && _activeWorkers > 1)
+                    {
+                        break; // Exit this worker
+                    }
+                    
+                    // Reset timer if we need to stay
                     lastWorkTime = DateTime.UtcNow;
                 }