Java并发工具类如Collections.synchronizedList的理解及实践

原创迈不过友情╰ 2024-09-29 21:00 85阅读 0赞

`Collections.synchronizedList()`是Java中一个常用的并发工具类，它主要用于创建一个线程安全的列表。

理解：
1. **线程安全**：这意味着无论何时多个线程访问这个列表，都不会导致数据不一致的问题。
2. **同步机制**：内部使用了同步锁（如`ReentrantLock`）来保证在任何时刻只有一个线程能够修改列表内容。

实践：
1. **创建线程安全列表**：直接调用`Collections.synchronizedList()`，传入一个普通的列表对象即可。
```java
List<String> originalList = new ArrayList<>();
// ... 添加元素到originalList

List<String> synchronizedList = Collections.synchronizedList(originalList);
```
2. **在多线程环境下使用**：将同步后的列表赋值给需要共享的变量，然后在多线程场景中进行操作。
```java
// 多线程示例
class ThreadA implements Runnable {
    private List<String> synchronizedList;

ThreadA(List<String> originalList) {
        synchronizedList = Collections.synchronizedList(originalList);
    }

@Override
    public void run() {
        // 在线程A中操作synchronizedList
        synchronized (synchronizedList)) {
            synchronizedList.add("New Element A");
        }
    }
}

class ThreadB implements Runnable {
    private List<String> synchronizedList;

ThreadB(List<String> originalList) {
        synchronizedList = Collections.synchronizedList(originalList);
    }

@Override
    public void run() {
        // 在线程B中操作synchronizedList
        synchronized (synchronizedList)) {
            synchronizedList.add("New Element B");
        }
    }
}

public class Main {
    public static void main(String[] args) {
        List<String> originalList = new ArrayList<>();
        // ... 添加元素到originalList

ThreadA threadA = new ThreadA(originalList);
        ThreadB threadB = new ThreadB(originalList);

threadA.start();
        threadB.start();

try {
            threadA.join();
            threadB.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Final List: " + synchronizedList));
    }
}
```
这段代码首先创建了一个原始列表和两个线程（ThreadA 和 ThreadB）。然后将同步后的列表赋值给这两个线程的列表变量。

在线程启动后，它们会在各自的run()方法中操作列表。由于列表是线程安全的，因此在这个多线程环境下，列表的内容不会发生错误。

最后，主线程通过join()方法等待两个线程完成任务。当所有线程都结束时，输出最终同步后的列表内容。