1. import java.util.concurrent.atomic.AtomicInteger;
  3. public class LogCompactor {
  5. private static final AtomicInteger counter = new AtomicInteger(0);
  7. public static String getLogEntry() {
  8. // Increment the counter for each log entry.
  9. int current = counter.incrementAndGet();
  11. // Format the log entry with the counter.
  12. return "Log Entry " + current;
  13. }
  15. public static void resetCounter() {
  16. // Reset the counter.
  17. counter.set(0);
  18. }
  20. public static void main(String[] args) throws InterruptedException {
  21. // Simulate a scenario where log entries are generated rapidly.
  22. for (int i = 0; i < 10; i++) {
  23. String logEntry = getLogEntry();
  24. System.out.println(logEntry);
  25. Thread.sleep(100); // Simulate some processing time.
  26. }
  28. System.out.println("--- Resetting Log Counter ---");
  29. resetCounter();
  31. for (int i = 0; i < 5; i++) {
  32. String logEntry = getLogEntry();
  33. System.out.println(logEntry);
  34. Thread.sleep(150);
  35. }
  36. }
  37. }

Add your comment