blob: 422e34fd16006a3be56818c669fe997bbf4bc2a8 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package akka
import scala.concurrent.forkjoin.ForkJoinPool
import com.newrelic.api.agent.NewRelic
case class PoolMetrics(poolName:String, data:Map[String,Int])
object PoolMetrics {
def apply(pool: ForkJoinPool) = new PoolMetrics(pool.getClass.getSimpleName, toMap(pool))
def toMap(pool: scala.concurrent.forkjoin.ForkJoinPool):Map[String,Int] = Map[String,Int](
"ActiveThreadCount" -> pool.getActiveThreadCount,
"Parallelism" -> pool.getParallelism,
"PoolSize" -> pool.getPoolSize,
"QueuedSubmissionCount" -> pool.getQueuedSubmissionCount,
"StealCount" -> pool.getStealCount.toInt,
"QueuedTaskCount" -> pool.getQueuedTaskCount.toInt,
"RunningThreadCount" -> pool.getRunningThreadCount
)
}
class PoolMetricsSender(forkJoinPool:ForkJoinPool) extends Runnable {
def run() {
val pool = PoolMetrics(forkJoinPool)
println(s"Sending Metrics to NewRelic -> ${pool}")
pool.data.map{case(k,v) => NewRelic.recordMetric(s"${pool.poolName}:${k}",v)}
}
}
|