File tree Expand file tree Collapse file tree 3 files changed +6
-6
lines changed
disjob-admin/ruoyi-admin/src/main/resources/templates
disjob-test/src/main/java/cn/ponfee/disjob/test/handler Expand file tree Collapse file tree 3 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ disjob # 主项目①
5151- Supervisor与Worker通过注册中心相互发现,支持的注册中心有:Database、Redis、Consul、Nacos、Zookeeper、Etcd
5252- Supervisor负责生成任务,把任务派发给Worker执行,支持的任务派发方式有:Redis、Http
5353- 需要指定Job的分组(job-group),Job的任务只会派发给指定组的Worker执行
54- - 提供拆分任务的能力 ,重写拆分方法[ JobHandler#split] ( disjob-core/src/main/java/cn/ponfee/disjob/core/handle/JobSplitter.java ) 即可拆分为多个任务,实现分布式任务及并行执行
54+ - 提供任务分片的能力 ,重写拆分方法[ JobHandler#split] ( disjob-core/src/main/java/cn/ponfee/disjob/core/handle/JobSplitter.java ) 即可拆分为多个任务,实现分布式任务及并行执行
5555- 支持暂停和取消运行中的任务,已暂停的任务可恢复继续执行,执行失败的任务支持重试
5656- 支持任务保存(savepoint)其执行状态,让手动或异常暂停的任务能从上一次的执行状态中恢复继续执行
5757- 任务在执行时若抛出[ PauseTaskException] ( disjob-core/src/main/java/cn/ponfee/disjob/core/exception/PauseTaskException.java ) ,会暂停对应实例下的全部任务(包括分布在不同worker机器中的任务)
@@ -169,7 +169,7 @@ disjob.registry.consul:
169169
170170举个简单的例子:统计在` (0,1万亿]`区间内质数的个数。如果是单机单线程CPU的话要统计很长时间,这里我们就可以使用`Disjob`框架提供的分布式并行执行的能力来解决该类问题。
171171
172- 1. **拆分任务 **
172+ 1. **任务分片 **
173173
174174先根据当前的机器资源情况来决定拆分任务的数量,比如我们有5台机器及每台2 core CPU(质数统计是CPU密集型),决定拆分为10个任务。
175175
@@ -240,8 +240,8 @@ Worker接收到子任务后,会提交到框架自定义的线程池中执行
240240| 任务分片 | 不支持 | 静态分片 | 广播 | 广播、动态分片 |
241241| 保存执行快照 | 不支持 | 不支持 | 不支持 | 支持 |
242242| 停止及恢复 | 不支持 | 不支持 | 终止运行中的任务 | 暂停执行中的任务、恢复已暂停的任务 |
243- | 后台管理 | 不支持 | 支持 | 支持 | 支持 |
244243| 失败重试 | 不支持 | 支持 | 支持 | 支持 |
244+ | 后台管理 | 不支持 | 支持 | 支持 | 支持 |
245245| 监控告警 | 不支持 | 邮件 | 邮件 | 暂不支持 |
246246| 查看执行日志 | 不支持 | 支持 | 支持 | 暂不支持 |
247247
Original file line number Diff line number Diff line change @@ -172,7 +172,7 @@ <h2 tabindex="-1" id="user-content-features" dir="auto"><a class="heading-link"
172172 < li > Supervisor与Worker通过注册中心相互发现,支持的注册中心有:Database、Redis、Consul、Nacos、Zookeeper、Etcd</ li >
173173 < li > Supervisor负责生成任务,把任务派发给Worker执行,支持的任务派发方式有:Redis、Http</ li >
174174 < li > 需要指定Job的分组(job-group),Job的任务只会派发给指定组的Worker执行</ li >
175- < li > 提供拆分任务的能力 ,重写拆分方法< a href ="https://github.com/dromara/disjob/blob/master/disjob-core/src/main/java/cn/ponfee/disjob/core/handle/JobSplitter.java "> JobHandler#split</ a > 即可拆分为多个任务,实现分布式任务及并行执行</ li >
175+ < li > 提供任务分片的能力 ,重写拆分方法< a href ="https://github.com/dromara/disjob/blob/master/disjob-core/src/main/java/cn/ponfee/disjob/core/handle/JobSplitter.java "> JobHandler#split</ a > 即可拆分为多个任务,实现分布式任务及并行执行</ li >
176176 < li > 支持暂停和取消运行中的任务,已暂停的任务可恢复继续执行,执行失败的任务支持重试</ li >
177177 < li > 支持任务保存(savepoint)其执行状态,让手动或异常暂停的任务能从上一次的执行状态中恢复继续执行</ li >
178178 < li > 任务在执行时若抛出< a href ="https://github.com/dromara/disjob/blob/master/disjob-core/src/main/java/cn/ponfee/disjob/core/exception/PauseTaskException.java "> PauseTaskException</ a > ,会暂停对应实例下的全部任务(包括分布在不同worker机器中的任务)</ li >
@@ -316,7 +316,7 @@ <h2 tabindex="-1" id="user-content-user-guide" dir="auto"><a class="heading-link
316316 < h2 tabindex ="-1 " id ="user-content-example " dir ="auto "> < a class ="heading-link " href ="#example "> Example< svg class ="octicon octicon-link " viewBox ="0 0 16 16 " version ="1.1 " width ="16 " height ="16 " aria-hidden ="true "> < path d ="m7.775 3.275 1.25-1.25a3.5 3.5 0 1 1 4.95 4.95l-2.5 2.5a3.5 3.5 0 0 1-4.95 0 .751.751 0 0 1 .018-1.042.751.751 0 0 1 1.042-.018 1.998 1.998 0 0 0 2.83 0l2.5-2.5a2.002 2.002 0 0 0-2.83-2.83l-1.25 1.25a.751.751 0 0 1-1.042-.018.751.751 0 0 1-.018-1.042Zm-4.69 9.64a1.998 1.998 0 0 0 2.83 0l1.25-1.25a.751.751 0 0 1 1.042.018.751.751 0 0 1 .018 1.042l-1.25 1.25a3.5 3.5 0 1 1-4.95-4.95l2.5-2.5a3.5 3.5 0 0 1 4.95 0 .751.751 0 0 1-.018 1.042.751.751 0 0 1-1.042.018 1.998 1.998 0 0 0-2.83 0l-2.5 2.5a1.998 1.998 0 0 0 0 2.83Z "> </ path > </ svg > </ a > </ h2 >
317317 < p dir ="auto "> 举个简单的例子:统计在< code > (0,1万亿]</ code > 区间内质数的个数。如果是单机单线程CPU的话要统计很长时间,这里我们就可以使用< code > Disjob</ code > 框架提供的分布式并行执行的能力来解决该类问题。</ p >
318318 < ol dir ="auto ">
319- < li > < strong > 拆分任务 </ strong > </ li >
319+ < li > < strong > 任务分片 </ strong > </ li >
320320 </ ol >
321321 < p dir ="auto "> 先根据当前的机器资源情况来决定拆分任务的数量,比如我们有5台机器及每台2 core CPU(质数统计是CPU密集型),决定拆分为10个任务。</ p >
322322 < ol start ="2 " dir ="auto ">
Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ public class PrimeCountJobHandler extends JobHandler {
4545 private static final long SAVEPOINT_INTERVAL_MS = 10 * 1000 ;
4646
4747 /**
48- * 拆分任务 ,自定义控制任务的拆分数量
48+ * 任务分片 ,自定义控制任务的拆分数量
4949 *
5050 * @param jobParamString the job param
5151 * @return task list
You can’t perform that action at this time.
0 commit comments