多线程管理一款功能强大、配置灵活、高性能异步编排框架 _框架

一飞开源，介绍创意、新奇、有趣、实用的免费开源应用、系统、软件、硬件及技术，一个探索、发现、分享、使用与互动交流的开源技术社区平台。致力于打造活力开源社区，共建开源新生态！

一、开源项目简介本框架是什么
Gobrs-Async是一款功能强大、配置灵活、带有全链路异常回调、内存优化、异常状态管理于一身的高性能异步编排框架。为企业提供在复杂应用场景下动态任务编排的能力。针对于复杂场景下，异步线程复杂性、任务依赖性、异常状态难控制性；Gobrs-Async为此而生。
二、开源协议
使用Apache-2.0开源协议
三、界面展示为什么写这个项目
在开发复杂中台业务过程中，难免会遇到调用各种中台业务数据，而且会出现复杂的中台数据依赖关系，在这种情况下。代码的复杂程度就会增加。如下图所示：

文章插图

在电商平台业务中，各中台数据可能依赖商品Product 数据，而且需要依赖特殊属性中 Item的数据。（有朋友会问，为什么Product 数据不和 Item数据出自同一个中台呢？中台业务发展是多样性的，不同业务中台设计方式不同，难道我们就不对接了吗？所以我们要针对于这种复杂多变的中台业务数据提供技术支撑才是一个合格的开发者应该做的）而且Item数据是HTTP的服务，但Product 是rpc服务。如果按照Future的开发方式。我们可能会这样开发

// 并行处理任务 Product 、 Item 的任务 @Resource List paraExectors; // 依赖于Product 和 Item的 任务 @Resource List serExectors; public void testFuture(HttpServletRequest httpServletRequest) { DataContext dataContext = new DataContext(); dataContext.setHttpServletRequest(httpServletRequest); List list = new ArrayList<>(); for (AsyncTask asyncTask : paraExectors) { Future submit = GobrsThreadPoolExecutor.submit(() -> { asyncTask.com.gobrs.async.com.gobrs.async.test.task(dataContext, null); }); list.add(submit); } for (Future future : list) { try { future.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } List ser = new ArrayList<>(); for (AsyncTask asyncTask : serExectors) { Future submit = gobrsThreadPoolExecutor.submit(() -> { asyncTask.com.gobrs.async.com.gobrs.async.test.task(dataContext, null); }); ser.add(submit); } for (Future future : ser) { try { future.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } }

存在的问题
以上示例中，Product数据是通过RPC 方式获取， Item是通过HTTP服务获取，大家都知道， RPC性能要高于HTTP性能。但是通过Future 的方式， get会阻塞等待 Item数据返回后才会往下执行。这样的话，图书音像、装修数据、限购数据等都要等待Item数据返回，但是这些中台并不依赖Item返回的数据，所以会产生等待时间影响系统整体QPS 。
起源

文章插图

作者通过对开源中间件的源码详细阅读和二次开发的经验和使用心得总结而来。
用户的一些使用体验包括业务的需求

Gobrs-Async 核心能力

文章插图

四、功能概述能解决什么问题
能解决 CompletableFuture 所不能解决的问题。怎么理解呢？
传统的Future、CompleteableFuture一定程度上可以完成任务编排，并可以把结果传递到下一个任务。如CompletableFuture有then方法，但是却无法做到对每一个执行单元的回调。譬如A执行完毕成功了，后面是B，我希望A在执行完后就有个回调结果，方便我监控当前的执行状况，或者打个日志什么的。失败了，我也可以记录个异常信息什么的。
此时，CompleteableFuture就无能为力了。
Gobrs-Async框架提供了这样的回调功能。并且，如果执行成功、失败、异常、超时等场景下都提供了管理线程任务的能力！
场景概述场景一