码迷,mamicode.com
首页 > 编程语言 > 详细

SimpleReact: 基于Java 8简单的FRP Fluent API

时间:2015-06-20 23:35:28      阅读:362      评论:0      收藏:0      [点我收藏+]

标签:

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

使用SimpleReact能够方便扩展微服务,它能用于管理微服务的远程调用,能够应付高并发大型高性能平台的要求。

使用SimpleReact能够建立非堵塞的微服务和REST客户端。

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

List<CompletableFuture<Integer>> futures = new SimpleReact()
            .<Integer> react(() -> 1, () -> 2, () -> 3)
            .with(it -> it * 100);

在这个案例中,3个supplier产生三个数字,这些都能并行地执行,当它们完成每个数字以后将乘以100,这也是作为一个并行的单独任务执行(由ForkJoinPool 或可配置的任务执行器),Simple React将立即返回Future对象集合列表,这些任务也将异步执行,不会有任何堵塞。

new SimpleReact()
            .<Integer> react(() -> 1, () -> 2, () -> 3)
            .then(it -> it * 100)
            .then(it -> "*" + it)


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。

更多复杂应用案例可见

项目:aol/simple-react · GitHub



SimpleReact: 基于Java 8简单的FRP Fluent API

标签:

原文地址:http://my.oschina.net/u/1441440/blog/469169

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!