并发安全问题：Java集合类的并发读写操作示例？

原创逃离我推掉我的手 2024-10-12 10:48 41阅读 0赞

在Java中，由于并发访问集合，可能会出现线程安全问题。以下是一个关于并发读写操作的例子：

```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ConcurrentCollectionsExample {

private static Lock lock = new ReentrantLock();

public void readWrite() {
        // 假设有一个集合，每个元素代表一个任务
        ArrayList<Runnable> tasks = new ArrayList<>();

// 添加一些任务到集合中
        for (int i = 0; i < 10; i++) {
            tasks.add(new Task("Task " + i)));
        }

try {
            // 获取锁
            lock.lock();

// 并发读写操作，模拟多个线程同时访问
            for (Runnable task : tasks) {
                System.out.println(task.getName() + " is running by thread..."));
                // 假设任务执行时间较长
                Thread.sleep(1000);
            }

} catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            lock.unlock();
        }
    }

private static class Task implements Runnable {

private String name;

public Task(String name) {
            this.name = name;
        }

@Override
        public void run() {
            System.out.println("Thread started by " + name + "..."));
        }
    }
}
```

在这个例子中，我们创建了一个`ConcurrentCollectionsExample`类，它有一个`readWrite()`方法来演示并发读写操作。每次执行任务时，都会模拟长时间运行，以示多线程并发访问的可能问题。