Spring Batch 是一个轻量级的、完善的批处理框架,旨在帮助企业建立健壮、高效的批处理应用。Spring Batch是Spring的一个子项目,使用Java语言并基于Spring框架为基础开发,使得已经使用 Spring 框架的开发者或者企业更容易访问和利用企业服务。 Spring Batch 提供了大量可重用的组件,包括了日志、追踪、事务、任务作业统计、任务重启、跳过、重复、资源管理。对于大数据量和高性能的批处理任务,Spring Batch 同样提供了高级功能和特性来支持,比如分区
并发
通过channel、互斥锁、定时器三者结合,完成了一个并发处理的函数接口。
通过传入协程池数、超时时间来限制协程的并发处理(协程池的数量应该小于数据循环处理的次数)。
参数中指定待处理的数据以及循环的次数,以及注册回调函数来处理自己的数据。如果传入的参数是数组,那么在回调函数中通过协程调用的索引号即可判断需要处理的是第几个元素。
type HanleParam struct {
Data interface{} `comment:待处理的数据,会传入回调函数中`
Num int