1. import java.util.concurrent.ArrayBlockingQueue;
  2. import java.util.concurrent.BlockingQueue;
  3. public class SandboxQueueEnvironment {
  4. private static final int QUEUE_SIZE = 10;
  5. private static final BlockingQueue<String> taskQueue = new ArrayBlockingQueue<>(QUEUE_SIZE);
  6. public static BlockingQueue<String> getTaskQueue() {
  7. return taskQueue;
  8. }
  9. public static void main(String[] args) {
  10. //Example Usage
  11. BlockingQueue<String> queue = getTaskQueue();
  12. // Add some tasks
  13. queue.add("Task 1");
  14. queue.add("Task 2");
  15. queue.add("Task 3");
  16. //Demonstrate retrieving tasks (without async)
  17. System.out.println("Task 1: " + queue.take());
  18. System.out.println("Task 2: " + queue.take());
  19. System.out.println("Task 3: " + queue.take());
  20. }
  21. }

Add your comment