Dataflow Programming API for Java?

Question

I am looking for a Dataflow / Concurrent Programming API for Java.
I know there's DataRush, but it's not free. What I'm interested in specifically is multicore data processing, and not distributed, which rules out MapReduce or Hadoop.
Any thoughts?
Thanks, Rollo

Answer 1

Does the built in Java concurrent package meet your needs? It's a very nice package, built in ThreadPools, CopyOnWriteCollections, Executors, Future. We use it to process large volumns of data in thread pools.

Answer 2

Might try the upcoming fork/join library which will (hopefully) be in Java 7 as part of the JSR 166y update.

Main project page: - http://gee.cs.oswego.edu/dl/concurrency-interest/index.html

Pointers to lots of links about what it is: - http://tech.puredanger.com/java7#jsr166

Answer 3

You might try gpars; it apparently has implementations of data flow variables and streams in Java even though it is geared towards providing concurrent programming goodies for Groovy.