GPars - producer / up-to-ten consumers

gistfile1.groovy

import groovyx.gpars.dataflow.DataflowQueue
import static groovyx.gpars.dataflow.Dataflow.task
import static groovyx.gpars.dataflow.Dataflow.operator

/**
 * A simple producer consumer sample showing use of the DataflowQueue class.
 */
def words = ['Groovy', 'fantastic', 'concurrency', 'fun', 'enjoy', 'safe', 'GPars', 'data', 'flow']
final def buffer = new DataflowQueue()

task {
    for (word in words) {
        buffer << word.toUpperCase()
    }
}

operator(inputs:[buffer], outputs:[], maxForks: 10) {value->
    println ('' + value + Thread.currentThread())
}

sleep 3000