Java并发流库SimpleReact

[sena4654]

Simple-React 为 Java 8 增加了高级异步 Streams 和数据结构。这是一个 Java 8 的并发流库，提供三中 Stream 类型（LazyFutureStream、SimpleReactStream、EagerFutureStream）和三种异步数据结构（Queue、Topic、Signal）。

SimpleReact来自AOL的一个小型的支持并发的库包，其直接基于Java 8的CompletableFuture, JDK函数接口和Streams API构建，它的Fluent API能够提供解决90%的Reactive使用场景，重要的是没有带入任何复杂性。可以实现Functional Reactive Programming范式(简称：FRP，函数式响应编程)。

使用SimpleReact能够方便扩展微服务，它能用于管理微服务的远程调用，能够应付高并发大型高性能平台的要求。使用SimpleReact能够建立非堵塞的微服务和REST客户端。

SimpleReact启动于Supplier数组，其主要产生其他函数需要响应的数据，每个supplier会传递给Executor执行，都是以单独的线程执行方式。

React then允许事件reactor能够被串联，不像"React with"，只返回一个Future集合，React then是一个fluent接口，能够返回React builder，允许以后的reactor能够被加入串联链条中，React then不会堵塞，React with能够在React then以后调用，只要React then提供访问完整的CompleteableFuture API，CompleteableFuture 能通过 SimpleReact.react(streamOfCompleteableFutures)被传递回SimpleReact。

项目地址： https://github.com/huangjie2016/reacts