tb启动

2018-07-27  本文已影响0人  7d29b558374e

TBScheduleManagerFactory 持用InitialThread

核心是init方法

接下来是
InitialThread.start();

核心是 initialData()

  public void initialData() throws Exception {
        /** 递归创建永久根节点(/ttest/creditjob)并写入版本信息 */
        this.zkManager.initial();
        /** 创建永久子节点 baseTaskType */
        this.scheduleDataManager = new ScheduleDataManager4ZK(this.zkManager);
        /** 创建永久子节点 strategy 和 factory */
        this.scheduleStrategyManager = new ScheduleStrategyDataManager4ZK(this.zkManager);
        if(this.start) {
            this.scheduleStrategyManager.registerManagerFactory(this);
            if(this.timer == null) {
                this.timer = new Timer("TBScheduleManagerFactory-Timer");
            }

            if(this.timerTask == null) {
                this.timerTask = new ManagerFactoryTimerTask(this);
                this.timer.schedule(this.timerTask, 2000L, (long)this.timerInterval);
            }
        }

    }
上一篇 下一篇

猜你喜欢

热点阅读