Thread pool monitoring - set number of threads directly from pool info

Author: OndroMih

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

@@ -66,13 +66,19 @@ public void onThreadAllocateEvent(AbstractThreadPool threadPool, Thread thread)
         grizzlyMonitoring.getThreadPoolProbeProvider().threadAllocatedEvent(
                 monitoringId, threadPool.getConfig().getPoolName(),
                 thread.getId());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override
     public void onThreadReleaseEvent(AbstractThreadPool threadPool, Thread thread) {
         grizzlyMonitoring.getThreadPoolProbeProvider().threadReleasedEvent(
                 monitoringId, threadPool.getConfig().getPoolName(),
                 thread.getId());
+        grizzlyMonitoring.getThreadPoolProbeProvider().setCurrentThreadCountEvent(
+                monitoringId, threadPool.getConfig().getPoolName(),
+                threadPool.getSize());
     }
 
     @Override

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

@@ -76,4 +76,10 @@ public void threadReturnedToPoolEvent(
         @ProbeParam("monitoringId") String monitoringId,
         @ProbeParam("threadPoolName") String threadPoolName,
         @ProbeParam("threadId") long threadId) {}
+
+    @Probe(name="setCurrentThreadCountEvent")
+    public void setCurrentThreadCountEvent(
+        @ProbeParam("monitoringId") String monitoringId,
+        @ProbeParam("threadPoolName") String threadPoolName,
+        @ProbeParam("currentThreadCount") int currentThreadCount) {}
 }

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

@@ -162,6 +162,17 @@ public void threadReturnedToPoolEvent(
         }
     }
 
+    @ProbeListener("glassfish:kernel:thread-pool:setCurrentThreadCountEvent")
+    public void setCurrentThreadCountEvent(
+            @ProbeParam("monitoringId") String monitoringId,
+            @ProbeParam("threadPoolName") String threadPoolName,
+            @ProbeParam("currentThreadCount") int currentThreadCount) {
+
+        if (name.equals(monitoringId)) {
+            this.currentThreadCount.setCount(currentThreadCount);
+        }
+    }
+
     @Reset
     public void reset() {
         if (threadPoolConfig != null) {