com.dangdang.ddframe.job.internal.execution

类 ExecutionService

java.lang.Object

com.dangdang.ddframe.job.internal.execution.ExecutionService

public class ExecutionService
extends Object

执行作业的服务.

作者:

zhangliang, caohao

构造器概要

构造器

构造器和说明
ExecutionService(CoordinatorRegistryCenter coordinatorRegistryCenter, JobConfiguration jobConfiguration)

方法概要

方法

限定符和类型	方法和说明
void	clearMisfire(List<Integer> items) 清除任务被错过执行的标记.
void	clearRunningInfo(List<Integer> items) 清除分配分片序列号的运行状态.
List<Integer>	getMisfiredJobItems(List<Integer> items) 获取标记被错过执行的任务分片项.
boolean	hasRunningItems() 判断是否还有执行中的作业.
boolean	hasRunningItems(List<Integer> items) 判断分片项中是否还有执行中的作业.
boolean	isCompleted(int item) 判断该分片是否已完成.
boolean	misfireIfNecessary(List<Integer> items) 如果满足条件，设置任务被错过执行的标记.
void	registerJobBegin(JobExecutionMultipleShardingContext jobExecutionShardingContext) 注册作业启动信息.
void	registerJobCompleted(JobExecutionMultipleShardingContext jobExecutionShardingContext) 注册作业完成信息.
void	removeExecutionInfo() 删除作业执行时信息.
void	setMisfire(List<Integer> items) 设置任务被错过执行的标记.
void	setNeedFixExecutionInfoFlag() 设置修复运行时分片信息标记的状态标志位.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ExecutionService

public ExecutionService(CoordinatorRegistryCenter coordinatorRegistryCenter,
                JobConfiguration jobConfiguration)

方法详细资料

registerJobBegin

public void registerJobBegin(JobExecutionMultipleShardingContext jobExecutionShardingContext)

注册作业启动信息.

参数:

jobExecutionShardingContext - 作业运行时分片上下文

registerJobCompleted

public void registerJobCompleted(JobExecutionMultipleShardingContext jobExecutionShardingContext)

注册作业完成信息.

参数:

jobExecutionShardingContext - 作业运行时分片上下文

setNeedFixExecutionInfoFlag

public void setNeedFixExecutionInfoFlag()

设置修复运行时分片信息标记的状态标志位.

clearRunningInfo

public void clearRunningInfo(List<Integer> items)

清除分配分片序列号的运行状态.

用于作业服务器恢复连接注册中心而重新上线的场景, 先清理上次运行时信息.

参数:

items - 需要清理的分片项列表

misfireIfNecessary

public boolean misfireIfNecessary(List<Integer> items)

如果满足条件，设置任务被错过执行的标记.

参数:

items - 需要设置错过执行的任务分片项

返回:

是否满足misfire条件

setMisfire

public void setMisfire(List<Integer> items)

设置任务被错过执行的标记.

参数:

items - 需要设置错过执行的任务分片项

getMisfiredJobItems

public List<Integer> getMisfiredJobItems(List<Integer> items)

获取标记被错过执行的任务分片项.

参数:

items - 需要获取标记被错过执行的任务分片项

返回:

标记被错过执行的任务分片项

clearMisfire

public void clearMisfire(List<Integer> items)

清除任务被错过执行的标记.

参数:

items - 需要清除错过执行的任务分片项

removeExecutionInfo

public void removeExecutionInfo()

删除作业执行时信息.

isCompleted

public boolean isCompleted(int item)

判断该分片是否已完成.

参数:

item - 运行中的分片路径

返回:

该分片是否已完成

hasRunningItems

public boolean hasRunningItems(List<Integer> items)

判断分片项中是否还有执行中的作业.

参数:

items - 需要判断的分片项列表

返回:

分片项中是否还有执行中的作业

hasRunningItems

public boolean hasRunningItems()

判断是否还有执行中的作业.

返回:

是否还有执行中的作业