Druid Supervisor启动task流程分析

前言

        继前一篇文章关于supervisor启动流程分析的启动过程，然后来分析一下supervisor启动后是如何启动并管理task的运行的。又是如何将KafkaTask的对象创建的。
上图

        创建完持续执行的supervisor线程后，紧接着通过一个定时的单线程池来创建RunNotice()对象并放入notice队列中供supervisor进行poll并运行handle()方法。定时的时间则是配置的task的运行周期，默认是1秒。
当supervisor获取到RunNotice的时候，开始执行RunNotice的hadle(), 然后开始执行创建task并将创建的kafkaTask添加到TaskMaster管理的TaskQueue中供taskRunner执行。整个task的创建和被执行的过程是消费者模式启动的。
        taskRunner调用task的start方法后开始具体的数据传输。此处的taskRunner包含：ForkingTaskRunner、HttpRemoteTaskRunne

Druid Supervisor启动task流程分析最先出现在Python成神之路。