Estoy buscando una API de Programación de Flujo de Datos/Concurrencia para Java.
Sé que hay DataRush, pero no es gratis. Lo que me interesa específicamente es el procesamiento de datos multinúcleo, y no se distribuye, lo que excluye MapReduce o Hadoop.
¿Alguna idea?
Gracias, RolloAPI de programación de flujo de datos para Java?
¿La construido en Java concurrent paquete de satisfacer sus necesidades? Es un paquete muy agradable, construido en ThreadPools, CopyOnWriteCollections, Executors, Future. Lo usamos para procesar grandes volmenes de datos en grupos de hilos.
Podría probar la próxima biblioteca de tenedor/unión que (con suerte) estará en Java 7 como parte de la actualización de JSR 166y.
la página principal del proyecto: - http://gee.cs.oswego.edu/dl/concurrency-interest/index.html
Punteros a un montón de enlaces sobre lo que es: - http://tech.puredanger.com/java7#jsr166
Usted puede tratar de gpars; aparentemente tiene implementaciones de variables de flujo de datos y flujos en Java a pesar de que está orientado a proporcionar recursos de programación concurrentes para Groovy.
https://github.com/rfqu/df4j es una biblioteca de flujo de datos simple pero potente. Si carece de algunas características deseadas, se pueden agregar fácilmente. Puede explotar java.concurrent.ExecutorService.
[Akka] (http://doc.akka.io/docs/akka/1.3.1/java/dataflow.html) tiene capacidades de flujo de datos. – thSoft