com.alibaba.schedulerx.worker.container

类 ContainerPool

java.lang.Object

com.alibaba.schedulerx.worker.container.ContainerPool

直接已知子类:

ThreadContainerPool

public abstract class ContainerPool
extends Object

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
ContainerPool()

方法概要

限定符和类型	方法和说明
boolean	contain(String uniqueId)
abstract boolean	destroyByInstance(long jobInstanceId) destroy pool by jobInstance
Container	get(String uniqueId)
Map<String,Container>	getContainerMap()
abstract JobContext	getContext()
void	put(String uniqueId, Container container)
void	remove(String uniqueId)
abstract void	removeContext()
void	setContainerMap(Map<String,Container> containerMap)
abstract void	setContext(JobContext jobContext)
abstract void	submit(long jobId, long jobInstanceId, long taskId, Container container, int consumerSize) submit task container

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

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

构造器详细资料

ContainerPool

public ContainerPool()

方法详细资料

getContainerMap

public Map<String,Container> getContainerMap()

setContainerMap

public void setContainerMap(Map<String,Container> containerMap)

get

public Container get(String uniqueId)

put

public void put(String uniqueId,
                Container container)

remove

public void remove(String uniqueId)

contain

public boolean contain(String uniqueId)

submit

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

submit task container

参数:

jobId - job id

jobInstanceId - instance identification

taskId - task identification

container - running container

consumerSize - running container service max capacity

destroyByInstance

public abstract boolean destroyByInstance(long jobInstanceId)

destroy pool by jobInstance

参数:

jobInstanceId - instance identification

setContext

public abstract void setContext(JobContext jobContext)

getContext

public abstract JobContext getContext()

removeContext

public abstract void removeContext()