Java集合框架操作不当引发的并发问题示例

原创青旅半醒 2024-12-06 09:42 21阅读 0赞

在Java集合框架中，如果没有正确地处理并发访问，可能会导致数据不一致的问题。以下是一个简单的示例：

```java
import java.util.concurrent.*;
import java.util.*;

public class ConcurrentCollectionsExample {

private List<String> list = new CopyOnWriteArrayList<>();

// 生产者线程
    public void producerThread() {
        for (int i = 0; i < 10; i++) {
            list.add("Item " + i);
            try {
                Thread.sleep(500); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        for (String item : list) {
            System.out.println("Consumed Item: " + item);
        }
    }

public static void main(String[] args) throws InterruptedException {

// 创建生产者和消费者线程
        ExecutorService producerExecutor = Executors.newSingleThreadExecutor();
        ExecutorService consumerExecutor = Executors.newSingleThreadExecutor();

Thread producerThread = new Thread(new Runnable() {
            @Override
            public void run() {
                ConcurrentCollectionsExample example = new ConcurrentCollectionsExample();
                example.producerThread();
                producerExecutor.shutdown(); // 关闭生产者线程执行器
            }
        })));

Thread consumerThread = new Thread(new Runnable() {
            @Override
            public void run() {
                ConcurrentCollectionsExample example = new ConcurrentCollectionsExample();
                example.consumerThread();
                consumerExecutor.shutdown(); // 关闭消费者线程执行器
            }
        })));

producerThread.start(); // 启动生产者线程
        consumerThread.start(); // 启动消费者线程

producerExecutor.awaitTermination(60, TimeUnit.SECONDS)); // 等待生产者线程完全结束
    }
}
```

在这个示例中，我们创建了一个可变的列表，并通过两个线程分别进行生产（添加元素）和消费（查看并删除元素）操作。如果没有正确地同步，可能会出现数据不一致的问题。