From be07f2cded403b5939d5b7c0817444dd9b3f9e4e Mon Sep 17 00:00:00 2001 From: Michael Moss Date: Tue, 13 Sep 2016 18:23:41 -0400 Subject: = core, log-reporter: added getQueuedSubmissionCount #390 (#392) --- .../src/main/scala/kamon/util/executors/ExecutorMetricRecorder.scala | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'kamon-core') diff --git a/kamon-core/src/main/scala/kamon/util/executors/ExecutorMetricRecorder.scala b/kamon-core/src/main/scala/kamon/util/executors/ExecutorMetricRecorder.scala index 465205b2..82655e9a 100644 --- a/kamon-core/src/main/scala/kamon/util/executors/ExecutorMetricRecorder.scala +++ b/kamon-core/src/main/scala/kamon/util/executors/ExecutorMetricRecorder.scala @@ -30,6 +30,7 @@ object ForkJoinPools { def getActiveThreadCount(fjp: T): Long def getRunningThreadCount(fjp: T): Long def getQueuedTaskCount(fjp: T): Long + def getQueuedSubmissionCount(fjp: T): Long } implicit object ScalaForkJoin extends ForkJoinMetrics[ForkJoinPool] { @@ -38,6 +39,7 @@ object ForkJoinPools { def getRunningThreadCount(fjp: ForkJoinPool) = fjp.getActiveThreadCount.toLong def getActiveThreadCount(fjp: ForkJoinPool) = fjp.getRunningThreadCount.toLong def getQueuedTaskCount(fjp: ForkJoinPool) = fjp.getQueuedTaskCount + def getQueuedSubmissionCount(fjp: ForkJoinPool) = fjp.getQueuedSubmissionCount } @@ -47,6 +49,7 @@ object ForkJoinPools { def getRunningThreadCount(fjp: JavaForkJoinPool) = fjp.getActiveThreadCount.toLong def getActiveThreadCount(fjp: JavaForkJoinPool) = fjp.getRunningThreadCount.toLong def getQueuedTaskCount(fjp: JavaForkJoinPool) = fjp.getQueuedTaskCount + def getQueuedSubmissionCount(fjp: JavaForkJoinPool) = fjp.getQueuedSubmissionCount } } @@ -57,6 +60,7 @@ abstract class ForkJoinPoolMetrics(instrumentFactory: InstrumentFactory) extends def activeThreads: Gauge def runningThreads: Gauge def queuedTaskCount: Gauge + def queuedSubmissionCount: Gauge } object ForkJoinPoolMetrics { @@ -72,6 +76,7 @@ object ForkJoinPoolMetrics { val activeThreads = gauge("active-threads", forkJoinMetrics.getActiveThreadCount(fjp)) val runningThreads = gauge("running-threads", forkJoinMetrics.getRunningThreadCount(fjp)) val queuedTaskCount = gauge("queued-task-count", forkJoinMetrics.getQueuedTaskCount(fjp)) + val queuedSubmissionCount = gauge("queued-submission-count", forkJoinMetrics.getQueuedSubmissionCount(fjp)) } } } -- cgit v1.2.3