Spring SmartLifecycle:如何精准控制Bean的生命周期

public interface SmartLifecycle extends Lifecycle {
    
    // 关键方法1：启动组件（自动触发）
    void start();
    
    // 关键方法2：停止组件（带异步通知）
    default void stop(Runnable callback) {
        stop();
        callback.run();
    }
    
    // 关键方法3：相位控制（数值越小优先级越高）
    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(); // 连接池预热
            running = true;
        }
    }

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

    @Override
    public int getPhase() {
        return Integer.MIN_VALUE + 1000; // 高优先级组件
    }
}

@Slf4j
@Configuration
public class SensitiveWordsConfiguration implements SmartLifecycle {

    /**
     * lifeRunning
     */
    private volatile boolean lifeRunning = false;
    
    /**
     * 更新时间间隔
     */
    private static final long UPDATE_TIME_SECONDS = 10 * 60;
    
    /**
     * 是否终止线程
     */
    private volatile boolean threadStop = false;
    /**
     * taskExecutor
     */
    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;
    /**
     * 当前线程任务
     */
    private Future<?> future;
    
    /**
     * 实现热更新，修改词典后自动加载
     */
    private void startScheduledUpdate() {
        while (!threadStop && !Thread.currentThread().isInterrupted()) {
            try {
                log.debug("SensitiveWordConfig#startScheduledUpdate start update...");
                
                //这里做业务处理
                //...
                
                TimeUnit.SECONDS.sleep(UPDATE_TIME_SECONDS);
            } catch (InterruptedException e) {
                log.info("SensitiveWordConfig#startScheduledUpdate interrupted: {}", e.getMessage());
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    @Override
    public void start() {
        // 启动定时更新任务线程
        this.future = taskExecutor.submit(this::startScheduledUpdate);
        lifeRunning = true;
    }

    @Override
    public void stop() {
        threadStop = true;
        // 主动终止当前线程的（否则会持续sleep直到线程池shutdownNow导致占用停止时间）
        this.future.cancel(true);
        lifeRunning = false;
    }

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

}