如何用 Java Deque 处理并发数据

在Java中，Deque（双端队列）是一种允许从两端添加和删除元素的集合

1. 使用ConcurrentLinkedDeque类：

ConcurrentLinkedDeque是一个线程安全的、基于链接节点的、非阻塞的Deque实现。它适用于高并发场景。以下是如何使用ConcurrentLinkedDeque处理并发数据的示例：

import java.util.concurrent.ConcurrentLinkedDeque;

public class ConcurrentDequeExample {
    public static void main(String[] args) {
        ConcurrentLinkedDeque<Integer> deque = new ConcurrentLinkedDeque<>();

        // 生产者线程
        Thread producer = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                deque.addFirst(i);
                System.out.println("Produced: " + i);
            }
        });

        // 消费者线程
        Thread consumer = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                Integer item = deque.pollLast();
                System.out.println("Consumed: " + item);
            }
        });

        producer.start();
        consumer.start();
    }
}

2. 使用Collections.synchronizedList()方法包装LinkedList或ArrayDeque：

如果你需要一个线程安全的Deque，但ConcurrentLinkedDeque不满足你的需求，你可以使用Collections.synchronizedList()方法将LinkedList或ArrayDeque包装为线程安全的Deque。请注意，这种方法可能会导致性能下降，因为所有操作都需要同步。

import java.util.ArrayList;
import java.util.Collections;
import java.util.Deque;
import java.util.LinkedList;

public class SynchronizedDequeExample {
    public static void main(String[] args) {
        Deque<Integer> deque = Collections.synchronizedList(new LinkedList<>());

        // 生产者线程
        Thread producer = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                synchronized (deque) {
                    deque.addFirst(i);
                    System.out.println("Produced: " + i);
                }
            }
        });

        // 消费者线程
        Thread consumer = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                synchronized (deque) {
                    Integer item = deque.pollLast();
                    System.out.println("Consumed: " + item);
                }
            }
        });

        producer.start();
        consumer.start();
    }
}

在这两个示例中，我们分别使用了ConcurrentLinkedDeque和Collections.synchronizedList()方法来处理并发数据。你可以根据你的需求和场景选择合适的方法。