com.alibaba.schedulerx.worker.batch

类 BaseReqHandler<T>

java.lang.Object

com.alibaba.schedulerx.worker.batch.BaseReqHandler<T>

直接已知子类:

ContainerStatusReqHandler, TaskDispatchReqHandler, TMStatusReqHandler

public abstract class BaseReqHandler<T>
extends Object

used for every parallel/Grid job instance every parallel/Grid task master has a BaseReqHandler, a BaseReqHandler will batchly retrieve reqs then merge these reqs into a batch request for hugely reducing network reqs number;

作者:

yanxun on 2019/1/5.

字段概要

字段

限定符和类型	字段和说明
protected AtomicInteger	activeRunnableNum onging runnable number, every subclass implement process method should decrement this value when a job was done.
protected ThreadPoolExecutor	batchProcessSvc
protected long	defaultSleepMs
protected long	emptySleepMs
protected TaskMasterPool	taskMasterPool

构造器概要

构造器

构造器和说明
BaseReqHandler(long jobInstanceId, int coreBatchThreadNum, int maxBatchThreadNum, int batchSize, ReqQueue<T> queue, String batchProcessThreadName, String batchRetrieveThreadName)

方法概要

限定符和类型	方法和说明
void	clear()
T	getLatestRequest()
boolean	isActive() queue has remaining or at least on runnable running, using this method with attention because batch process may be async so activeRunnableNum should be decrement when job really down, you can look #{TMStatusReqHandler} for example;
void	process(long jobInstanceId, List<T> reqs)
abstract void	process(long jobInstanceId, List<T> reqs, String workerIdAddr) logic implemented by subclass for processing this batch of reqs
void	setBatchSize(int batchSize)
void	setWorkThreadNum(int workThreadNum)
void	start()
void	stop()
void	submitRequest(T request)
List<T>	syncHandleReqs(int pageSize, String workerIdAddr)

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

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

字段详细资料

taskMasterPool

protected TaskMasterPool taskMasterPool

batchProcessSvc

protected ThreadPoolExecutor batchProcessSvc

defaultSleepMs

protected long defaultSleepMs

emptySleepMs

protected long emptySleepMs

activeRunnableNum

protected AtomicInteger activeRunnableNum

onging runnable number, every subclass implement process method should decrement this value when a job was done.

构造器详细资料

BaseReqHandler

public BaseReqHandler(long jobInstanceId,
                      int coreBatchThreadNum,
                      int maxBatchThreadNum,
                      int batchSize,
                      ReqQueue<T> queue,
                      String batchProcessThreadName,
                      String batchRetrieveThreadName)

方法详细资料

start

public void start()

process

public abstract void process(long jobInstanceId,
                             List<T> reqs,
                             String workerIdAddr)

logic implemented by subclass for processing this batch of reqs

参数:

jobInstanceId - id of job instance which these reqs belong to.

reqs - batch of reqs

workerIdAddr - of PullModel

process

public void process(long jobInstanceId,
                    List<T> reqs)

setWorkThreadNum

public void setWorkThreadNum(int workThreadNum)

setBatchSize

public void setBatchSize(int batchSize)

stop

public void stop()

clear

public void clear()

submitRequest

public void submitRequest(T request)
                   throws Exception

抛出:

Exception

getLatestRequest

public T getLatestRequest()

syncHandleReqs

public List<T> syncHandleReqs(int pageSize,
                              String workerIdAddr)

isActive

public boolean isActive()

queue has remaining or at least on runnable running, using this method with attention because batch process may be async so activeRunnableNum should be decrement when job really down, you can look #{TMStatusReqHandler} for example;

返回: