1. import java.util.concurrent.Executors;
  2. import java.util.concurrent.ScheduledExecutorService;
  3. import java.util.concurrent.TimeUnit;
  5. public class LogReloader {
  7. private final Runnable reloadTask;
  8. private final long reloadIntervalMillis;
  9. private ScheduledExecutorService scheduler;
  10. private boolean running = false;
  12. public LogReloader(Runnable reloadTask, long reloadIntervalMillis) {
  13. this.reloadTask = reloadTask;
  14. this.reloadIntervalMillis = reloadIntervalMillis;
  15. this.scheduler = Executors.newSingleThreadScheduledExecutor();
  16. }
  18. public void start() {
  19. if (!running) {
  20. scheduler.scheduleAtFixedRate(reloadTask, 0, reloadIntervalMillis, TimeUnit.MILLISECONDS);
  21. running = true;
  22. }
  23. }
  25. public void stop() {
  26. if (running) {
  27. scheduler.shutdown();
  28. running = false;
  29. }
  30. }
  32. public static void main(String[] args) {
  33. // Example Usage
  34. LogReloader reloader = new LogReloader(() -> {
  35. // Simulate reloading log entries
  36. System.out.println("Reloading log entries...");
  37. try {
  38. Thread.sleep(1000); // Simulate some work
  39. } catch (InterruptedException e) {
  40. Thread.currentThread().interrupt();
  41. }
  42. System.out.println("Log entries reloaded.");
  43. }, 5000); // Reload every 5 seconds
  45. reloader.start();
  47. try {
  48. Thread.sleep(20000); // Run for 20 seconds
  49. } catch (InterruptedException e) {
  50. Thread.currentThread().interrupt();
  51. }
  53. reloader.stop();
  54. System.out.println("Log reloader stopped.");
  55. }
  56. }

Add your comment