Java中实现数据库秒级周期性数据拉取与任务调度

import java.time.Duration;
import java.time.Instant;
import java.util.HashMap;
import java.util.List;

public class SimpleDatabasePoller {

    // 模拟一个数据库工具类，包含检查文件导入状态的方法
    static class SqlUtils {
        public HashMap<String, List<String>> checkFileImport() {
            // 模拟数据库查询耗时
            try {
                Thread.sleep(50); // 模拟50毫秒的数据库查询
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            System.out.println("  [DB] 正在执行数据库查询，获取最新状态...");
            // 返回模拟数据
            HashMap<String, List<String>> map = new HashMap<>();
            map.put("status", List.of("PROCESSING"));
            return map;
        }
    }

    private final SqlUtils sqlUtils;

    public SimpleDatabasePoller(SqlUtils sqlUtils) {
        this.sqlUtils = sqlUtils;
    }

    public void startPolling() {
        System.out.println("启动基础数据库轮询器...");
        while (true) { // 无限循环，持续轮询
            Instant start = Instant.now();
            try {
                // 执行数据库查询操作
                HashMap<String, List<String>> status = sqlUtils.checkFileImport();
                // 在此处处理查询结果，例如打印状态、更新UI等
                System.out.println("  [Poller] 获取到的状态: " + status);

                Instant end = Instant.now();
                long durationMillis = Duration.between(start, end).toMillis();
                long sleepTime = 1000 - durationMillis; // 减去任务执行时间，尽量保证总周期为1秒

                if (sleepTime > 0) {
                    Thread.sleep(sleepTime); // 暂停剩余时间，以达到每秒执行一次
                } else {
                    System.out.println("  [Warning] 任务执行时间超过1秒，未进行休眠。");
                }

            } catch (InterruptedException e) {
                System.err.println("轮询线程被中断，即将退出: " + e.getMessage());
                Thread.currentThread().interrupt(); // 重新设置中断状态
                break; // 退出循环
            } catch (Exception e) {
                System.err.println("数据库查询发生错误: " + e.getMessage());
                // 错误处理逻辑，如记录日志、发送警报、短暂休眠后重试等
                try {
                    Thread.sleep(5000); // 错误发生时，休眠更长时间避免频繁重试
                } catch (InterruptedException ex) {
                    Thread.currentThread().interrupt();
                    break;
                }
            }
        }
    }

    public static void main(String[] args) {
        SimpleDatabasePoller poller = new SimpleDatabasePoller(new SqlUtils());
        // 在一个新线程中启动轮询，避免阻塞主线程
        new Thread(poller::startPolling, "DatabasePollerThread").start();

        // 模拟主应用的其他操作
        System.out.println("主应用正在运行...");
        try {
            Thread.sleep(5000); // 让主应用运行5秒
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        System.out.println("主应用完成其操作，但轮询线程可能仍在运行。");
        // 实际应用中需要机制来停止轮询线程
    }
}