1. import java.io.File;
  2. import java.io.IOException;
  3. import java.nio.file.Files;
  4. import java.nio.file.Path;
  5. import java.nio.file.Paths;
  6. import java.time.Instant;
  7. import java.util.concurrent.Executors;
  8. import java.util.concurrent.ScheduledExecutorService;
  9. import java.util.concurrent.TimeUnit;
  11. public class TimestampProcessTeardown {
  13. private static final int CLEANUP_INTERVAL = 60; // seconds
  14. private static final int NUM_THREADS = 4;
  16. private static ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(NUM_THREADS);
  18. public static void main(String[] args) throws IOException {
  19. // Example usage: Create some test files with timestamps
  20. createTestFiles();
  22. // Schedule the cleanup task to run periodically
  23. scheduler.scheduleAtFixedRate(CleanupTask::run, 0, CLEANUP_INTERVAL, TimeUnit.SECONDS);
  25. // Keep the main thread alive to allow the scheduler to run.
  26. // In a real application, this could be replaced with a more appropriate
  27. // long-running task or service. For testing, we just keep it running.
  28. try {
  29. Thread.sleep(60 * 60 * 1000); // Run for an hour
  30. } catch (InterruptedException e) {
  31. Thread.currentThread().interrupt();
  32. } finally {
  33. scheduler.shutdown();
  34. }
  36. }
  38. static void createTestFiles() throws IOException{
  39. File testDir = new File("test_timestamps");
  40. if(!testDir.exists()){
  41. testDir.mkdir();
  42. }
  43. for(int i = 0; i < 10; i++){
  44. Path filePath = Paths.get("test_timestamps/file_" + i + ".txt");
  45. Files.writeString(filePath, "Timestamp: " + Instant.now());
  46. }
  49. }
  51. static class CleanupTask implements Runnable {
  52. @Override
  53. public void run() {
  54. try {
  55. File testDir = new File("test_timestamps");
  56. if (testDir.exists() && testDir.isDirectory()) {
  57. File[] files = testDir.listFiles();
  58. if (files != null) {
  59. for (File file : files) {
  60. if (file.isFile() && file.getName().matches("file_\\d+\\.txt")) {
  61. long lastModified = file.lastModified();
  62. if (System.currentTimeMillis() - lastModified > 60 * 60 * 24) { // Delete files older than 1 day
  63. try {
  64. Files.deleteIfExists(Paths.get(file.getAbsolutePath()));
  65. System.out.println("Deleted: " + file.getAbsolutePath());
  66. } catch (IOException e) {
  67. System.err.println("Error deleting " + file.getAbsolutePath() + ": " + e.getMessage());
  68. }
  69. }
  70. }
  71. }
  72. }
  73. }
  74. } catch (IOException e) {
  75. System.err.println("Error during cleanup: " + e.getMessage());
  76. }
  77. }
  78. }
  79. }

Add your comment