您现在的位置是:首页 > 文章详情

stone-1.2.4 发布, 扩展任务池

日期:2023-10-19点击:60

1: 介绍

BeeTP是stone包下一款小型任务池组件,它支持单次任务,定时任务,聚合任务的处理,整体功能类似JUC包中的线程池。

2: 参考例子

 public class HelloTask implements BeeTask { public Object call() { return "Hello World"; } }
 public class MyTaskTest { public static void main(String[] args) throws Exception { BeeTaskServiceConfig config = new BeeTaskServiceConfig(); config.setWorkerKeepAliveTime(TimeUnit.SECONDS.toMillis(10)); BeeTaskService service = new BeeTaskService(config); //作为单次任务  BeeTaskHandle handle = service.submit(new HelloTask()); //作为定时任务  service.scheduleAtFixedRate(new HelloTask(), 0, 2, TimeUnit.SECONDS); //打印单次任务结果  System.out.println("Result:" + handle.get()); } }

单次任务,定时任务,聚合任务的接口提交方法使用的均是基于BeeTask的实现。

3: 修改内容

1:任务池代码重构,并进行精简处理

2:修复任务句柄中的取消时的并发性bug

3:在重构的基础上增加树状聚合型任务: BeeTreeTask,源码如下

 public interface BeeTreeTask<E> { /**  * return pre-split sub tasks  *  * @return sub tasks of current task  */  BeeTreeTask<E>[] getSubTasks(); /**  * execute call with handle array of sub tasks  *  * @param subTaskHandles handle array of sub tasks  * @return execution value of method call  * @throws Exception occurred in execution  */  E call(BeeTaskHandle<E>[] subTaskHandles) throws Exception; } 

4: 版本下载

 <dependency>  <groupId>io.github.chris2018998</groupId>  <artifactId>stone</artifactId>  <version>1.2.4</version> </dependency>

5: 项目地址

https://gitee.com/Chris2018998/stone

https://github.com/Chris2018998/stone

原文链接:https://www.oschina.net/news/262485
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章