类的使用
com.alibaba.schedulerx.worker.batch.ReqQueue

使用ReqQueue的程序包

程序包	说明
com.alibaba.schedulerx.worker.batch
com.alibaba.schedulerx.worker.master
com.alibaba.schedulerx.worker.pull

com.alibaba.schedulerx.worker.batch中ReqQueue的使用

参数类型为ReqQueue的com.alibaba.schedulerx.worker.batch中的构造器

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

com.alibaba.schedulerx.worker.master中ReqQueue的使用

声明为ReqQueue的com.alibaba.schedulerx.worker.master中的字段

限定符和类型	字段和说明
protected ReqQueue<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest>	MapTaskMaster.taskBlockingQueue
protected ReqQueue<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest>	MapTaskMaster.taskStatusReqQueue

com.alibaba.schedulerx.worker.pull中ReqQueue的使用

参数类型为ReqQueue的com.alibaba.schedulerx.worker.pull中的构造器

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