http://d.hatena.ne.jp/fumokmm/20110611/1307811572

sleepSort.groovy

def worker = { latch, num ->
    println "ready: $num"
    latch.countDown()
    Thread.sleep(num * 10)
    println num
}

def latch = new java.util.concurrent.CountDownLatch(args.size())
args.each {
    Thread.start worker.curry(latch, it as int)
}

sleepSortWithGpars.groovy

def latch = new java.util.concurrent.CountDownLatch(args.size())
groovyx.gpars.GParsPool.withPool(args.size() ?: 1) {
    args.eachParallel {
        println "ready: $it"
        latch.countDown()
        Thread.sleep((it as int) * 10)
        println it
    }
}

sleepSortWithGPars2.groovy

// 自分で理解できるよう噛み砕いて
// コメントなど追加
import static groovyx.gpars.GParsPool.*
import java.util.concurrent.*

def numbers = [8, 1, 4, 9, 3, 6]
def latch = new CountDownLatch(numbers.size())

withPool(numbers.size() ?: 1){ // <- awaitしてるので、数分スレッド確保
  numbers.eachParallel {
    latch.countDown()
    latch.await() // <- 全部の準備が終わるまで待つ
    Thread.sleep((it as int) * 10)
    println it
  }
}