xxl任务执行流程
2019-09-04 20:46:19 73 举报
xxl执行流程分析
作者其他创作
大纲/内容
slow线程池
执行器
xxl rpc调用
调度中心
具体执行任务的线程
trigger接口
fast线程池
任务完成回调通知接口
路由组件
任务执行完成以后，会将结果投递到任务执行回调队列，任务执行回调线程会去队列中去执行结果，去批量通知调度中心更新任务的执行结果
根据一定规则将启动任务投递到这俩线程池（JobTriggerPoolHelper）
广播任务不进行路由选择
获取执行结果同时更新job_log日志，如果有子任务就执行子任务，如果子任务还有依赖任务未完成，就将当前任务完成记录插入job_dependenc表，以待子任务其他依赖任务完成以后，在进行执行
任务执行回调线程
路由组件会根据JobInfo中的路由策略去选择对应的执行器地址（ExecutorRouter）
xxl给根据jobId来创建线程，相同的jobId的任务会在同一个线程中执行，每个线程中都有一个队列去存储具体的任务数据，线程异步去消费数据并执行
0 条评论
回复 删除
下一页
