What is a thread-safe queue in Java?

What is a thread-safe queue in Java?

A thread-safe queue in Java is a data structure that allows multiple threads to access it concurrently without causing data inconsistency.

How can I implement a thread-safe queue?

You can use the ConcurrentLinkedQueue or BlockingQueue interfaces from the java.util.concurrent package for thread-safe operations.

Can you show me a code example?

Sure! Here's a simple example using BlockingQueue:

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 < 5; 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 < 5; i++) {
                    int value = queue.take();
                    System.out.println("Consumed: " + value);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }).start();
    }
}

What are the advantages of using a thread-safe queue?

The main advantages include preventing data corruption, ensuring thread safety, and simplifying concurrent programming.