代码拉取完成,页面将自动刷新
一个简单的多用途异步任务执行框架
Maven
<dependency>
<groupId>com.github.jonzhang3</groupId>
<artifactId>aTask</artifactId>
<version>1.1.0</version>
</dependency>
TaskEngine engine = new TaskEngine.Builder()
.corePoolSize(3)// 设置核心线程池大小,默认为系统 CPU 核数
.maxPoolSize(100)// 设置线程池的最大大小,默认为 Integer.MAX_VALUE
.keepAliveSeconds(1000)// 设置线程的最大空闲时间,默认为 60 秒
// 设置任务等待队列的大小,默认为 Integer.MAX_VALUE
// 如果设置的为负数,则采用 SynchronousQueue,否则采用 LinkedBlockingQueue
.queueCapacity(20)
// 设置线程池的任务拒绝策略
.rejectedExecutionHandler(RejectedExecutionHandler)
.completedTaskHandler(handler)// 设置对已完成任务的处理回调
.build();
// 可通过 getRunningTasks() 方法获取当前正在执行的任务
Task task = engine.buildTask(ctx -> {
ctx.onProgress(100);// 设置进度值,将调用进度回调函数
ctx.onSuccess("1", "2", "3");// 设置任务执行成功,将调用结果回调函数
ctx.onError(Exception);// 设置任务执行失败,将调用结果回调函数
// 如果 onSuccess 和 onError 都调用了,则第首先执行的方法将会调用成功
})
.type("type")// 设置任务的类型
.progress(progress -> {})// 设置任务的进度回调
// 设置任务的结果回调
// 如果任务执行失败,error 则不为 null;如果任务执行成功,error 则为 null
.end((ctx, error) -> {
if(error != null) {// 执行成功
ctx.getResult();// 获取 onSuccess 设置的数据
} else {// 执行失败
log.error(error);// 打印错误
}
})
.build();
engine.go(task);// 最后调用 TaskEngine 的 go 方法执行该任务
task.await(); // 该方法会阻塞当前线程,如果你需要等待任务执行完成再继续执行,则调用该方法
ResultTask<String> resultTask = engine.buildResultTask(ctx -> {
ctx.onProgress(200);
return "success";// 返回结果数据
})
.type("type")
.progress(i -> {})
.build();
engine.go(resultTask);
// 获取返回结果
// 该方法会阻塞当前线程
String result = resultTask.get();
TaskGroup group = engine.prepareGroup();// 创建一个任务组
// 添加并执行一个任务
group.go(group.buildItem(ctx -> {
ctx.group().incrementCounter();// 计数器 +1(线程安全)
ctx.group().addData("data");// 设置数据,方便后续使用
}).build());
group.await();// 等待线程组中所有的任务执行完成
group.getCounter();// 获取计数器的结果
Data data = group.getData();// 获取组中任务执行时设置的数据(线程安全)
注册一个 ServletRegistrationBean 类
@Bean
public ServletRegistrationBean<StatViewServlet> druidStatViewServlet() {
TaskEngine engine = new TaskEngine.Builder()
.build();
engine.prepareGroup("test");
// 设置 TaskEngine
TaskStatService.setTaskEngine(engine);
// 注册 StatViewServlet,并为其设置路径
ServletRegistrationBean<StatViewServlet> registrationBean =
new ServletRegistrationBean<>(new StatViewServlet(), "/atask/*");
registrationBean.addInitParameter("username", "root");// 设置登录用户名
registrationBean.addInitParameter("password", "1234");// 设置登录密码
return registrationBean;
}
首先新建一个 TaskEngine
, 然后将其设置到 TaskStatService
// 也可以采用其他方式
static TaskEngine engine;
static {
engine = new TaskEngine.Builder()
.build();
TaskStatService.setTaskEngine(engine);
}
然后新建一个 Servlet
类,并添加 @WebServlet
注解
@WebServlet(
urlPatterns = "/atask/*",
initParams = {
@WebInitParam(name = "username", value = "admin"),
@WebInitParam(name = "password", value = "123456"),
}
)
public class ATaskStatServlet extends StatViewServlet {
}
不要忘了在启动类上添加 @ServletComponentScan
注解
@SpringBootApplication
@ServletComponentScan
public class DemoApplication {
}
监控页面:
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
1. 开源生态
2. 协作、人、软件
3. 评估模型