适用于Java的数据流编程API?

我正在寻找一个Java的数据流/并发编程API。
我知道有DataRush ,但它不是免费的。 我特别感兴趣的是多核数据处理,而不是分布式的,它排除了MapReduce或Hadoop 。
有什么想法吗?
谢谢,罗洛

你可以试试gpars ; 它显然具有Java中的数据流变量和流的实现,即使它是为Groovy提供并发编程的好东西。

可能会尝试即将到来的fork / join库,它将(有希望)作为JSR 166y更新的一部分在Java 7中。

主项目页面: – http://gee.cs.oswego.edu/dl/concurrency-interest/index.html

指向有关它的大量链接的指针: – http://tech.puredanger.com/java7#jsr166

内置的Java 并发包是否满足您的需求? 这是一个非常好的包,内置在ThreadPools,CopyOnWriteCollections,Executors,Future中。 我们使用它来处理线程池中的大量数据。

https://github.com/rfqu/df4j是一个简单但function强大的数据流库。 如果它缺少一些所需的function,可以轻松添加。 它可以利用java.concurrent.ExecutorService。