CSR-EHS: High-throughput Real-time Stream Processing in Java

流处理是一种编程范例，适用于必须以及时和响应的方式处理大量数据的数据驱动应用程序。示例应用包括视频处理、数字信号处理和业务流程监控。流编程的吸引力来自其概念上的简单性。程序是一组独立的过滤器，它们通过单向数据通道进行排他性通信。任何过滤器的输出行为都完全由其输入通道上的值决定，从而减少了数据竞争的机会。有趣的是，流处理语言提供的抽象与事件驱动的实时系统惊人地接近。 以前的研究表明，流程序可以在现代多处理器上非常有效地实现。该项目的目标是将基于流的编程与实时系统集成。 该项目扩展了Java，将流与对象联合收割机结合起来，并允许程序员将流计算与传统的面向对象组件集成在同一个Java虚拟机中。这项工作依赖于Java实时规范提供的设施，以确保流代码满足其目标应用程序的实时约束。 这个项目的更广泛的影响是引入了一个新的编程范式，可以被实时和传统的开发人员使用。 Java的选择有望简化采用，因为程序员可以使用主流开发环境、库和开发方法来编写流处理代码。

Stream processing is a programming paradigm suitable for the class of data driven applications that must manipulate high-volumes of data in a timely and responsive fashion. Example applications include video processing, digital signal processing, and monitoring of business processes. The appeal of stream programming comes from its conceptual simplicity. A program is a set of independent filters that communicate exclusively by the means of unidirectional data channels. The output behavior of any filter is completely determined by the value on its input channels, thus reducing the chances of data races. Interestingly, the abstractions provided by stream processing languages are surprisingly close to event-driven real-time systems. Previous research has shown that stream programs can be implemented very efficiently on modern multiprocessors. The goal of this project is to integrate stream-based programming with real-time systems. The project extends Java to combine streams with objects and allow programmers to integrate stream computations with traditional object-oriented components in the same Java virtual machine. The work relies on the facilities provided by the Real-time Specification for Java to ensure that streaming codes meet real-time constraints of their target application. The broader impact of this project is to introduce a new programming paradigm that can be used by real-time and traditional developers. The choice of Java is expected to ease adoption, as programmers can use mainstream development environments, libraries and development methodologies for writing stream processing code.