public interface SmartLifecycle extends Lifecycle {
    
    // 關(guān)鍵方法1：?jiǎn)?dòng)組件（自動(dòng)觸發(fā)）
    void start();
    
    // 關(guān)鍵方法2：停止組件（帶異步通知）
    default void stop(Runnable callback) {
        stop();
        callback.run();
    }
    
    // 關(guān)鍵方法3：相位控制（數(shù)值越小優(yōu)先級(jí)越高）
    int getPhase();
    
    // 其他方法
    boolean isAutoStartup();
    boolean isRunning();
}

@Component
public class DatabaseConnector implements SmartLifecycle {
    private volatile boolean running = false;
    private ConnectionPool pool;

    @Override
    public void start() {
        if (!running) {
            this.pool = initConnectionPool(); // 連接池預(yù)熱
            running = true;
        }
    }

    @Override
    public void stop() {
        if (running) {
            pool.safeRelease(); // 安全釋放連接
            running = false;
        }
    }

    @Override
    public int getPhase() {
        return Integer.MIN_VALUE + 1000; // 高優(yōu)先級(jí)組件
    }
}

@Slf4j
@Configuration
public class SensitiveWordsConfiguration implements SmartLifecycle {

    /**
     * lifeRunning
     */
    private volatile boolean lifeRunning = false;
    
    /**
     * 更新時(shí)間間隔
     */
    private static final long UPDATE_TIME_SECONDS = 10 * 60;
    
    /**
     * 是否終止線程
     */
    private volatile boolean threadStop = false;
    /**
     * taskExecutor
     */
    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;
    /**
     * 當(dāng)前線程任務(wù)
     */
    private Future<?> future;
    
    /**
     * 實(shí)現(xiàn)熱更新，修改詞典后自動(dòng)加載
     */
    private void startScheduledUpdate() {
        while (!threadStop && !Thread.currentThread().isInterrupted()) {
            try {
                log.debug("SensitiveWordConfig#startScheduledUpdate start update...");
                
                //這里做業(yè)務(wù)處理
                //...
                
                TimeUnit.SECONDS.sleep(UPDATE_TIME_SECONDS);
            } catch (InterruptedException e) {
                log.info("SensitiveWordConfig#startScheduledUpdate interrupted: {}", e.getMessage());
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    @Override
    public void start() {
        // 啟動(dòng)定時(shí)更新任務(wù)線程
        this.future = taskExecutor.submit(this::startScheduledUpdate);
        lifeRunning = true;
    }

    @Override
    public void stop() {
        threadStop = true;
        // 主動(dòng)終止當(dāng)前線程的（否則會(huì)持續(xù)sleep直到線程池shutdownNow導(dǎo)致占用停止時(shí)間）
        this.future.cancel(true);
        lifeRunning = false;
    }

    @Override
    public boolean isRunning() {
        return lifeRunning;
    }

}