GPars - producer-2 consumers

gistfile1.groovy

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

/**
 * 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()
    }
}

task {
    while (true) println buffer.val
}
task {
    while (true) println buffer.val
}