GPars Dataflow Queue with Cancel

GPars Dataflow Queue with Cancel

import static groovyx.gpars.dataflow.Dataflow.task
import groovyx.gpars.dataflow.DataflowQueue
import java.util.concurrent.atomic.AtomicBoolean

final def buffer = new DataflowQueue()
final done =  new AtomicBoolean()

def t = task {
	while(!done.get()) {
		def word = 	System.console().readLine 'Enter some text (or "stop" to stop): '
		buffer << word.toUpperCase()  //add to the buffer
	}
}

task {
	while(true) {
		def val = buffer.val  //read from the buffer in a loop
		println val
		if(val == "STOP") {
			println "You said stop, so I'm cancelling the other task."
			done.set(true)
			return
		}
	}
}

t.join()