flume源码学习3-自动reload配

        EventBus eventBus = new EventBus(agentName + "-event-bus" ); //实例化一个EventBus对象
        PollingPropertiesFileConfigurationProvider configurationProvider =
            new PollingPropertiesFileConfigurationProvider(agentName,
                configurationFile, eventBus, 30); //默认的检测文件是否更新的interval时间为30s
        components.add(configurationProvider); //添加到启动列表中，在start方法中会启动PollingPropertiesFileConfigurationProvider 的计划任务线程池
        application = new Application(components);
        eventBus.register(application); //向EventBus中注册Application对象，让Application对象作为时间的监听者

  public void start() {
....
    executorService = Executors.newSingleThreadScheduledExecutor(
            new ThreadFactoryBuilder().setNameFormat("conf-file-poller-%d" )
                .build()); //定义一个单线程的任务调度池
    FileWatcherRunnable fileWatcherRunnable =
        new FileWatcherRunnable(file , counterGroup ); //构建一个FileWatcherRunnable服务对象
    executorService.scheduleWithFixedDelay(fileWatcherRunnable, 0, interval,
        TimeUnit. SECONDS); //以interval为时间间隔运行FileWatcherRunnable
    lifecycleState = LifecycleState. START; // 设置为START状态
...
  }

    public void run() {
...
      long lastModified = file.lastModified(); //调用File.lastModified获取文件的上一次更新时的时间戳
      if (lastModified > lastChange) { //初始lastChange 为0
...
        lastChange = lastModified; // 设置本次的lastChange 为更新时间，如果下一次更新文件，lastModified 会大于这个lastChange 
        try {
          eventBus.post(getConfiguration());
        } 
.....
      }
    }
  }

@Subscribe
public synchronized void handleConfigurationEvent(MaterializedConfiguration conf) { //reload服务
  stopAllComponents();
  startAllComponents(conf);
}