How can I implement thread-safe queues in Java?

How can I implement thread-safe queues in Java?

You can use the ConcurrentLinkedQueue or BlockingQueue interfaces in Java for thread-safe queues. Would you like an example?

Yes, please provide an example using BlockingQueue.

Sure! Here's a simple example:

import java.util.concurrent.*;

public class ThreadSafeQueueExample {
    public static void main(String[] args) {
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>();

        // Producer thread
        new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    queue.put(i);
                    System.out.println("Produced: " + i);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }).start();

        // Consumer thread
        new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    int value = queue.take();
                    System.out.println("Consumed: " + value);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }).start();
    }
}

This code creates a producer that adds integers to the queue and a consumer that takes them out.

What happens if the queue is empty when the consumer tries to take an element?

If the queue is empty, the take() method will block the consumer thread until an element becomes available. This ensures that the consumer waits for new items to be produced.