Java守护线程实现清理数据库垃圾

什么是守护线程？与普通线程的区别

守护线程是在程序运行时在后台提供一种支持性的线程。与普通线程相比，守护线程有以下几个区别：

1. 终止条件

• 当所有用户线程结束时，守护线程会自动停止。
• 换句话说，守护线程不会阻止程序的终止，即使它们还没有执行完任务。

2. 生命周期

• 守护线程的生命周期与主线程或其他用户线程无关。
• 当所有的非守护线程都结束时，JVM 将会退出并停止守护线程的执行。

3. 线程优先级

• 守护线程的优先级默认与普通线程一样。
• 优先级较高的守护线程也不能够保证在其他线程之前执行。

4. 资源回收

• 守护线程通常被用于执行一些后台任务，例如垃圾回收、日志记录、定时任务等。
• 当只剩下守护线程时，JVM 会自动退出并且不会等待守护线程执行完毕。

注意事项

守护线程与普通线程在编写代码时没有太大的区别。可以通过将线程的setDaemon(true)方法设置为 true，将普通线程转换为守护线程。

总结

守护线程在程序运行过程中提供一种支持性的服务，会在所有的用户线程结束时自动停止。

代码示例

清理数据库垃圾数据

@Service
public class DatabaseCleanupDaemon implements Runnable {
    // 清理间隔，设置为每24小时执行一次
    private static final long CLEANUP_INTERVAL = TimeUnit.HOURS.toMillis(24);
    // 保留最近30天的数据
    private static final int DAYS_TO_KEEP = 30;

    @Override
    public void run() {
        // 将当前线程设置为守护线程
        Thread.currentThread().setDaemon(true);

        while (true) {
            try {
                // 执行清理操作
                cleanupOldChatRecords();
                // 休眠指定时间
                Thread.sleep(CLEANUP_INTERVAL);
            } catch (InterruptedException e) {
                // 如果线程被中断，退出循环
                Thread.currentThread().interrupt();
                break;
            } catch (Exception e) {
                // 记录清理过程中的错误
                System.err.println("Database cleanup failed: " + e.getMessage());
            }
        }
    }
    //具体清理垃圾数据的方法
    private void cleanupOldChatRecords() {
        // 计算30天前的日期
        LocalDateTime threshold = LocalDateTime.now().minusDays(DAYS_TO_KEEP);

        // 使用MyBatis-Plus的QueryWrapper构建删除条件
        QueryWrapper<ChatRecord> queryWrapper = new QueryWrapper<>();
        queryWrapper.lt("created_at", threshold);

        // 执行删除操作
        int deletedRows = chatRecordService.remove(queryWrapper);
        System.out.println("Cleaned up " + deletedRows + " old chat records.");
    }
}

调用

//主方法，用于演示守护线程的启动
public static void main(String[] args) {
    // 在实际应用中，这部分代码通常会在Spring Boot的启动类中配置
    DatabaseCleanupDaemon daemon = new DatabaseCleanupDaemon();
    Thread cleanupThread = new Thread(daemon);
    cleanupThread.setDaemon(true);
    cleanupThread.start();

    System.out.println("Main program is running. Cleanup daemon is working in the background.");
}