xin.bluesky.leiothrix.server.action

类 WorkerProcessorLauncher

java.lang.Object

xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

public class WorkerProcessorLauncher
extends Object

作者:

张轲

构造器概要

构造器

构造器和说明
WorkerProcessorLauncher(String taskId)

方法概要

限定符和类型	方法和说明
protected void	after()
protected void	before()
protected int	calAvailableProcessNum(NodeInfo worker)
protected xin.bluesky.leiothrix.server.action.LaunchLog	doLaunch()
xin.bluesky.leiothrix.server.action.LaunchLog	launch()
boolean	resourceIsNotEnough(String taskId)
void	setWorkerManager(WorkerManager workerManager)
void	setWorkerProcessorInvoker(WorkerProcessorInvoker workerProcessorInvoker)

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

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

构造器详细资料

WorkerProcessorLauncher

public WorkerProcessorLauncher(String taskId)

方法详细资料

launch

public xin.bluesky.leiothrix.server.action.LaunchLog launch()
                                                     throws ProcessorLaunchException,
                                                            NoResourceException,
                                                            NotAllowedLaunchException,
                                                            ProcessorRunningException

抛出:

ProcessorLaunchException

NoResourceException

NotAllowedLaunchException

ProcessorRunningException

before

protected void before()

doLaunch

protected xin.bluesky.leiothrix.server.action.LaunchLog doLaunch()
                                                          throws ProcessorRunningException

抛出:

ProcessorRunningException

after

protected void after()
              throws NoResourceException,
                     ProcessorLaunchException

抛出:

NoResourceException

ProcessorLaunchException

resourceIsNotEnough

public boolean resourceIsNotEnough(String taskId)

calAvailableProcessNum

protected int calAvailableProcessNum(NodeInfo worker)

setWorkerProcessorInvoker

public void setWorkerProcessorInvoker(WorkerProcessorInvoker workerProcessorInvoker)

setWorkerManager

public void setWorkerManager(WorkerManager workerManager)