com.alibaba.schedulerx.worker.container

类 ThreadContainerPool

java.lang.Object

com.alibaba.schedulerx.worker.container.ContainerPool

com.alibaba.schedulerx.worker.container.ThreadContainerPool

public class ThreadContainerPool
extends ContainerPool

作者:

xiaomeng.hxm

方法概要

限定符和类型	方法和说明
boolean	destroyByInstance(long jobInstanceId) destroy pool by jobInstance
JobContext	getContext()
static ThreadContainerPool	getInstance()
Object	getInstanceLock(long jobInstanceId) 获取指定任务实例锁对象
void	releaseInstanceLock(long jobInstanceId) 清除任务实例锁对象
void	removeContext()
void	setContext(JobContext jobContext)
void	submit(long jobId, long jobInstanceId, long taskId, Container container, int consumerSize) submit task container

从类继承的方法 com.alibaba.schedulerx.worker.container.ContainerPool

contain, get, getContainerMap, put, remove, setContainerMap

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

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

方法详细资料

getInstance

public static ThreadContainerPool getInstance()

submit

public void submit(long jobId,
                   long jobInstanceId,
                   long taskId,
                   Container container,
                   int consumerSize)

从类复制的说明: ContainerPool

submit task container

指定者:

submit 在类中 ContainerPool

参数:

jobId - job id

jobInstanceId - instance identification

taskId - task identification

container - running container

consumerSize - running container service max capacity

destroyByInstance

public boolean destroyByInstance(long jobInstanceId)

从类复制的说明: ContainerPool

destroy pool by jobInstance

指定者:

destroyByInstance 在类中 ContainerPool

参数:

jobInstanceId - instance identification

setContext

public void setContext(JobContext jobContext)

指定者:

setContext 在类中 ContainerPool

getContext

public JobContext getContext()

指定者:

getContext 在类中 ContainerPool

removeContext

public void removeContext()

指定者:

removeContext 在类中 ContainerPool

getInstanceLock

public Object getInstanceLock(long jobInstanceId)

从类复制的说明: ContainerPool

获取指定任务实例锁对象

指定者:

getInstanceLock 在类中 ContainerPool

返回:

releaseInstanceLock

public void releaseInstanceLock(long jobInstanceId)

从类复制的说明: ContainerPool

清除任务实例锁对象

指定者:

releaseInstanceLock 在类中 ContainerPool