Bug de GPars

gistfile1.groovy

import groovyx.gpars.GParsPool
 
def set = (1..10)
def cnt = 0
def r = new java.util.Random()
def baseThreads =  Thread.activeCount()
GParsPool.withPool(3) {
  println "Only 3 \"Starting thread\" call should exists until one \"Closing\""
  set.eachParallel{ aa ->
   synchronized(this.class) {
     cnt += 1
 	  println "Starting thread ${Thread.currentThread()}. Active threads: counter -> $cnt activeThreads -> ${(Thread.activeCount() - baseThreads)}"
   }
   sleep(100 + (r.nextInt() % 10))
  
   synchronized(this.class) {
     cnt -= 1
     println "Closing thread ${Thread.currentThread()}. Active threads: counter -> $cnt activeThreads -> ${(Thread.activeCount() - baseThreads)}"
 
 
   }
 }
}

GParsPool.withPool(3) {
  println "Same code with an extra pool nested. Everything goes bananas"
  set.eachParallel{ aa ->
   synchronized(this.class) {
     cnt += 1
 	  println "Starting thread ${Thread.currentThread()}. Active threads: counter -> $cnt activeThreads -> ${(Thread.activeCount() - baseThreads)}"
   }
   sleep(100 + (r.nextInt() % 10))
   
   GParsPool.withPool(2) {
     set.eachParallel { elem ->
       sleep(100 + (r.nextInt() % 100))
     }
   }
 
   synchronized(this.class) {
     cnt -= 1
     println "Closing thread ${Thread.currentThread()}. Active threads: counter -> $cnt activeThreads -> ${(Thread.activeCount() - baseThreads)}"
 
 
   }
 }
}