src/main/scala/akka/PoolMonitorAspect.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

package akka

import org.aspectj.lang.annotation._

@Aspect("perthis(poolMonitor())")
class PoolMonitorAspect {
  println("Created PoolMonitorAspect")

  @Pointcut("execution(scala.concurrent.forkjoin.ForkJoinPool.new(..)) && !within(PoolMonitorAspect)")
  protected def poolMonitor:Unit = {}

  @Before("poolMonitor() && this(pool)")
  def beforePoolInstantiation(pool: scala.concurrent.forkjoin.ForkJoinPool):Unit = {
    Tracer.collectPool(pool)
  }
}