Set setCurrentThreadCountEvent directly

Author: OndroMih

nucleus/core/kernel/src/main/java/com/sun/enterprise/v3/services/impl/monitor/ThreadPoolMonitor.java

@@ -86,6 +86,9 @@ public void onMaxNumberOfThreadsEvent(AbstractThreadPool threadPool, int maxNumb
         grizzlyMonitoring.getThreadPoolProbeProvider().maxNumberOfThreadsReachedEvent(
                 monitoringId, threadPool.getConfig().getPoolName(),
                 maxNumberOfThreads);
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
@@ -95,6 +98,9 @@ public void onTaskDequeueEvent(AbstractThreadPool threadPool, Runnable task) {
                 Thread.currentThread().getId());
         grizzlyMonitoring.getConnectionQueueProbeProvider().onTaskDequeuedEvent(
                 monitoringId, task.getClass().getName());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
@@ -104,24 +110,36 @@ public void onTaskCancelEvent(AbstractThreadPool threadPool, Runnable task) {
         grizzlyMonitoring.getThreadPoolProbeProvider().threadReturnedToPoolEvent(
                 monitoringId, threadPool.getConfig().getPoolName(),
                 Thread.currentThread().getId());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
     public void onTaskCompleteEvent(AbstractThreadPool threadPool, Runnable task) {
         grizzlyMonitoring.getThreadPoolProbeProvider().threadReturnedToPoolEvent(
                 monitoringId, threadPool.getConfig().getPoolName(),
                 Thread.currentThread().getId());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
     public void onTaskQueueEvent(AbstractThreadPool threadPool, Runnable task) {
         grizzlyMonitoring.getConnectionQueueProbeProvider().onTaskQueuedEvent(
                 monitoringId, task.getClass().getName());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
     public void onTaskQueueOverflowEvent(AbstractThreadPool threadPool) {
         grizzlyMonitoring.getConnectionQueueProbeProvider().onTaskQueueOverflowEvent(
                 monitoringId);
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 }