Spring Boot 2中如何优雅地实现持续扫描数据库并处理匹配数据？

public class DatabaseMonitor implements Runnable {

    private Thread thread;
    private volatile boolean runFlag = true; // 使用 volatile 保证线程可见性

    @PostConstruct
    public void startMonitoring() {
        thread = new Thread(this);
        thread.start();
    }

    @PreDestroy
    public void stopMonitoring() {
        runFlag = false;
        try {
            thread.join(); // 等待线程结束
        } catch (InterruptedException e) {
            // 记录日志或进行其他异常处理
            log.error("线程中断异常", e);
        }
    }

    @Override
    public void run() {
        while (runFlag) {
            // TODO: 在此处编写数据库扫描和业务处理逻辑
            // 例如：使用JdbcTemplate或JPA查询数据库，并根据条件处理匹配的行。
            try {
                // 数据库查询操作
                List<DataEntity> matchedData = fetchDataFromDatabase();
                // 数据处理操作
                processData(matchedData);

                Thread.sleep(5000); // 每5秒扫描一次，可根据实际情况调整
            } catch (InterruptedException e) {
                // 处理中断异常，例如设置runFlag为false
                Thread.currentThread().interrupt();
                log.error("任务中断", e);
            } catch (Exception e) {
                log.error("数据库扫描或数据处理异常", e);
                // 添加重试机制或其他错误处理策略
            }
        }
    }

    //  添加fetchDataFromDatabase() 和 processData() 方法实现数据库查询和数据处理逻辑
    private List<DataEntity> fetchDataFromDatabase() {
        // 使用JdbcTemplate或JPA进行数据库查询
        // ...
        return null; // 替换为实际的查询结果
    }

    private void processData(List<DataEntity> data) {
        // 处理查询到的数据
        // ...
    }
}