private void initScheduledTasks() {
		//更新服務(wù)列表
        if (clientConfig.shouldFetchRegistry()) {
            // registry cache refresh timer
            int registryFetchIntervalSeconds = clientConfig.getRegistryFetchIntervalSeconds();
            int expBackOffBound = clientConfig.getCacheRefreshExecutorExponentialBackOffBound();
            scheduler.schedule(
                    new TimedSupervisorTask(
                            "cacheRefresh",
                            scheduler,
                            cacheRefreshExecutor,
                            registryFetchIntervalSeconds,
                            TimeUnit.SECONDS,
                            expBackOffBound,
                            new CacheRefreshThread()
                    ),
                    registryFetchIntervalSeconds, TimeUnit.SECONDS);
        }
		...
		//略去其他代碼

public void run() {
        Future future = null;
        try {
	    //使用Future，可以設(shè)定子線程的超時時間，這樣當(dāng)前線程就不用無限等待了
            future = executor.submit(task);
            threadPoolLevelGauge.set((long) executor.getActiveCount());
            //指定等待子線程的最長時間
            future.get(timeoutMillis, TimeUnit.MILLISECONDS);  // block until done or timeout
            //delay是個很有用的變量，后面會用到，這里記得每次執(zhí)行任務(wù)成功都會將delay重置
            delay.set(timeoutMillis);
            threadPoolLevelGauge.set((long) executor.getActiveCount());
        } catch (TimeoutException e) {
            logger.error("task supervisor timed out", e);
            timeoutCounter.increment();

            long currentDelay = delay.get();
            //任務(wù)線程超時的時候，就把delay變量翻倍，但不會超過外部調(diào)用時設(shè)定的最大延時時間
            long newDelay = Math.min(maxDelay, currentDelay * 2);
            //設(shè)置為最新的值，考慮到多線程，所以用了CAS
            delay.compareAndSet(currentDelay, newDelay);
        } catch (RejectedExecutionException e) {
            //一旦線程池的阻塞隊列中放滿了待處理任務(wù)，觸發(fā)了拒絕策略，就會將調(diào)度器停掉
            if (executor.isShutdown() || scheduler.isShutdown()) {
                logger.warn("task supervisor shutting down, reject the task", e);
            } else {
                logger.error("task supervisor rejected the task", e);
            }

            rejectedCounter.increment();
        } catch (Throwable e) {
            //一旦出現(xiàn)未知的異常，就停掉調(diào)度器
            if (executor.isShutdown() || scheduler.isShutdown()) {
                logger.warn("task supervisor shutting down, can't accept the task");
            } else {
                logger.error("task supervisor threw an exception", e);
            }

            throwableCounter.increment();
        } finally {
            //這里任務(wù)要么執(zhí)行完畢，要么發(fā)生異常，都用cancel方法來清理任務(wù)；
            if (future != null) {
                future.cancel(true);
            }
            
	    //只要調(diào)度器沒有停止，就再指定等待時間之后在執(zhí)行一次同樣的任務(wù)
            if (!scheduler.isShutdown()) {
            	//這里就是周期性任務(wù)的原因：只要沒有停止調(diào)度器，就再創(chuàng)建一次性任務(wù)，執(zhí)行時間時dealy的值，
            	//假設(shè)外部調(diào)用時傳入的超時時間為30秒（構(gòu)造方法的入?yún)imeout），最大間隔時間為50秒(構(gòu)造方法的入?yún)xpBackOffBound)
            	//如果最近一次任務(wù)沒有超時，那么就在30秒后開始新任務(wù)，
            	//如果最近一次任務(wù)超時了，那么就在50秒后開始新任務(wù)（異常處理中有個乘以二的操作，乘以二后的60秒超過了最大間隔50秒）
                scheduler.schedule(this, delay.get(), TimeUnit.MILLISECONDS);
            }
        }
    }

scheduler.schedule(this, delay.get(), TimeUnit.MILLISECONDS)