com.alibaba.schedulerx.worker.pull

类 ConsumerThread

java.lang.Object

com.alibaba.schedulerx.worker.container.ThreadContainer

com.alibaba.schedulerx.worker.pull.ConsumerThread

所有已实现的接口:

Container, Runnable

public class ConsumerThread
extends ThreadContainer

作者:

xiaomeng.hxm

字段概要

从类继承的字段 com.alibaba.schedulerx.worker.container.ThreadContainer

containerPool, masterActorSelection

构造器概要

构造器

构造器和说明
ConsumerThread(BlockingContainerQueue queue, ContainerPool containerPool, String taskMasterAkkaPath)
ConsumerThread(JobContext context, ContainerPool containerPool)

方法概要

限定符和类型	方法和说明
void	run()
void	stopRunning()

从类继承的方法 com.alibaba.schedulerx.worker.container.ThreadContainer

getContext, kill, setContext, start

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

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

构造器详细资料

ConsumerThread

public ConsumerThread(JobContext context,
                      ContainerPool containerPool)
               throws Exception

抛出:

Exception

ConsumerThread

public ConsumerThread(BlockingContainerQueue queue,
                      ContainerPool containerPool,
                      String taskMasterAkkaPath)
               throws Exception

抛出:

Exception

方法详细资料

run

public void run()

指定者:

run 在接口中 Runnable

覆盖:

run 在类中 ThreadContainer

stopRunning

public void stopRunning()