Hzero 任务调度分析

1.@JobHandler注解 实现IJobHandler接口 定义一个接口
2. ExecutorInit这个类实现了CommandLineRunner接口会在springboot启动后收集@JobHandler注解，将其注册到JobRegistry这个类中。

 public void run(String... args) throws Exception {
        this.scanJobHandler();
        ThreadFactory threadFactory = (new ThreadFactoryBuilder()).setNameFormat("scheduler-register-runner-%d").build();
        ExecutorService executor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(), threadFactory);
        executor.execute(new ExecutorInit.Registry());
    }

    private void scanJobHandler() {
        Map<String, Object> map = ApplicationContextHelper.getContext().getBeansWithAnnotation(JobHandler.class);
        Iterator var2 = map.values().iterator();

        while(var2.hasNext()) {
            Object service = var2.next();
            if (service instanceof IJobHandler) {
                JobHandler jobHandler = (JobHandler)ProxyUtils.getUserClass(service).getAnnotation(JobHandler.class);
                if (ObjectUtils.isEmpty(jobHandler)) {
                    logger.debug("could not get target bean , jobHandler : {}", service);
                } else {
                    JobRegistry.addJobHandler(jobHandler.value(), service);
                }
            }
        }

    }

4. JobExecuteController这个类，用于接收启动任务的请求，然后启动任务。
5. 期间会通过fegin调用任务调度服务。