Java集合框架中并发问题示例

原创雨点打透心脏的1/2处 2024-10-23 06:42 47阅读 0赞

在Java的集合框架中，由于多线程的存在，可能会出现并发问题。以下是一个简单示例：

```java
import java.util.ArrayList;
import java.util.List;

public class ConcurrentHashMapExample {

private static final int THREADS = 5; // 创建线程数量

public static void main(String[] args) {
        List<String> list = new ArrayList<>();

for (int i = 0; i < 100; i++) {
            list.add("Item " + i);
        }

runConcurrentThreads(list, THREADS);
    }

private static void runConcurrentThreads(List<String> list, int threads) {
        List<Thread> threadList = new ArrayList<>();

for (int i = 0; i < threads; i++) {
            Thread thread = new Thread(() -> addItemsToList(list));
            threadList.add(thread);
            thread.start();
        }

// 等待所有线程完成
        for (Thread thread : threadList) {
            try {
                thread.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

private static void addItemsToList(List<String> list) {
        for (int i = 0; i < 5; i++) { // 假设每次操作需要5毫秒
            try {
                Thread.sleep(5); // 模拟实际操作耗时
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            list.add("Item added at index " + (i * 10))); // 假设每次添加新元素
        }
    }
}
```

这个示例中，我们创建了一个包含100个元素的列表，并在一个多线程环境下向其中添加元素。由于线程同步问题，可能会导致结果不一致。

在实际应用中，需要使用Java并发工具类如`ConcurrentHashMap`、`ExecutorService`等来避免这些问题。