GPars demo

GPars demo

//     compile "org.codehaus.gpars:gpars:1.2.1"


import groovyx.gpars.GParsPool

...

    static void main(String[] args) {
        def aPromises = []

        for (int i = 0; i < 10; ++i) {
            aPromises << {
                println "START: ${Thread.currentThread().id}"
                Thread.sleep(5000)
                println "DONE: ${Thread.currentThread().id}"
            }
        }

        GParsPool.withPool(5) {
            println "BEFORE"
            GParsPool.executeAsyncAndWait aPromises
            println "AFTER"
        }
    }