1. import java.util.Scanner;
  2. import java.util.concurrent.atomic.AtomicBoolean;
  4. public class QueueMonitor {
  6. private static final Scanner scanner = new Scanner(System.in);
  7. private static AtomicBoolean running = true;
  9. public static void main(String[] args) {
  10. // Start the monitoring loop
  11. monitorQueue();
  12. }
  14. private static void monitorQueue() {
  15. while (running) {
  16. System.out.println("Press Ctrl+C to stop.");
  17. try {
  18. scanner.nextInt(); // Wait for user input to prevent busy-waiting
  19. } catch (Exception e) {
  20. if (e instanceof java.util.hasNextException) {
  21. // User pressed Ctrl+C
  22. running = false;
  23. }
  24. }
  25. // Simulate checking the queue (replace with actual queue polling logic)
  26. checkQueue();
  27. }
  28. System.out.println("Monitoring stopped.");
  29. }
  31. private static void checkQueue() {
  32. // Replace this with your actual queue checking logic.
  33. // This is a placeholder.
  34. System.out.println("Checking queue...");
  35. // Simulate queue processing
  36. try {
  37. Thread.sleep(1000); // Simulate a 1-second check interval
  38. } catch (InterruptedException e) {
  39. Thread.currentThread().interrupt();
  40. }
  41. System.out.println("Queue check complete.");
  42. }
  43. }

Add your comment