Java并发编程——条件变量和读写锁示例

原创淡淡的烟草味﹌ 2024-12-05 13:36 19阅读 0赞

在Java的并发编程中，条件变量和读写锁是两种重要的同步工具。下面我将为你详细解释这两种工具，并提供一些示例。

1. 条件变量：

条件变量用于线程间的通信，主要通过wait()、notifyAll()等方法进行操作。

示例：
```java
// 定义一个共享资源
int count = 0;

// 创建两个线程
Thread producer = new Thread(() -> {
    for (int i = 1; i <= 10; i++) {
        // 生产者向count加一
        synchronized (count) {
            count++;
            // 调用notifyAll()唤醒等待的消费者
            if (count == 11) {
                synchronized (count) {
                    count--;
                    count.notifyAll();
                }
            }
        }
    }
}));
Thread consumer = new Thread(() -> {
    while (true) {
        // 消费者从count减一
        synchronized (count) {
            if (count > 0) {
                count--;
                count.notify();
                break;
            } else {
                try {
                    count.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}));

// 启动线程
producer.start();
consumer.start();

// 结束示例代码
```

2. 读写锁：

读写锁（ReentrantReadWriteLock）是Java并发库中的一种锁机制，它允许多个读取操作同时进行，但对写入操作会进行阻塞。

示例：
```java
import java.util.concurrent.locks.ReentrantReadWriteLock;

// 定义一个共享资源
class Counter {
    private int count = 0;
    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();

public synchronized void increment() {
        lock.writeLock().lock();
        try {
            count++;
        } finally {
            lock.writeLock().unlock();
        }
    }

public synchronized int decrement() {
        lock.readLock().lock();
        try {
            if (count > 0) {
                count--;
                return count;
            } else {
                throw new IllegalArgumentException("Counter is already zero");
            }
        } finally {
            lock.readLock().unlock();
        }
    }

public synchronized int getCount() {
        lock.readLock().lock();
        try {
            return count;
        } finally {
            lock.readLock().unlock();
        }
    }
}
```

以上就是Java并发编程中条件变量和读写锁的简单介绍以及使用示例。在实际开发中，这两种工具能帮助你更高效地管理多线程之间的同步问题。