xin.bluesky.leiothrix.server.action

类 WorkerProcessorInvoker

java.lang.Object

xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

public class WorkerProcessorInvoker
extends Object

作者:

张轲

字段概要

字段

限定符和类型	字段和说明
protected static int	WORKER_MEMORY_REDUNDANCY
static int	WORKER_PROCESSOR_MEMORY

构造器概要

构造器

构造器和说明
WorkerProcessorInvoker()

方法概要

限定符和类型	方法和说明
int	calAvailableProcessNum(NodeInfo worker) 以内存来计算可分配的worker进程数量.
int	getPhysicalUpperLimitProcessNum(NodeInfo worker) 获得worker物理机的自身内存,所允许启动的进程数量上限
void	invoke(String taskId, String mainClass, String workerIp, String workerJarPath)

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

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

字段详细资料

WORKER_PROCESSOR_MEMORY

public static final int WORKER_PROCESSOR_MEMORY

WORKER_MEMORY_REDUNDANCY

protected static final int WORKER_MEMORY_REDUNDANCY

构造器详细资料

WorkerProcessorInvoker

public WorkerProcessorInvoker()

方法详细资料

invoke

public void invoke(String taskId,
                   String mainClass,
                   String workerIp,
                   String workerJarPath)
            throws ProcessorLaunchException

抛出:

ProcessorLaunchException

getPhysicalUpperLimitProcessNum

public int getPhysicalUpperLimitProcessNum(NodeInfo worker)

获得worker物理机的自身内存,所允许启动的进程数量上限

参数:

worker - worker

返回:

the max processor num of this worker calculated by physical memory

calAvailableProcessNum

public int calAvailableProcessNum(NodeInfo worker)

以内存来计算可分配的worker进程数量.

参数:

worker - worker

返回:

the available processor number can be launched