Java并发编程中，AQS（AbstractQueuedSynchronizer）的使用场景示例

原创ゝ一纸荒年。 2024-10-08 05:21 26阅读 0赞

AQS（AbstractQueuedSynchronizer）是Java并发库中的一个核心组件，主要用于实现线程同步和互斥。以下是一些使用AQS场景的示例：

1. **独占锁（Exclusive Lock）**：
   ```java
   // 乐观锁，如果资源没有被修改，则获取锁
   class Resource {
       private int value;
       
       // 设定值，如果值已存在则抛出异常
       public void set(int value) throws IllegalStateException {
           if (this.value == value) {
               return; // 如果值没有改变，则直接返回
           }
           synchronized (Resource.class) {
               if (this.value != value) {
                   throw new IllegalStateException("Value has been modified by another thread"); // 抛出异常
               }
               this.value = value; // 设置成功，更新资源
           }
       }

// 获取锁，如果资源已经被其他线程修改则阻塞
       public synchronized int get() throws InterruptedException {
           while (this.value != 0) { // 如果资源已被其他线程占用，则等待
               wait(); // 调用wait()方法让当前线程进入等待状态
           }
           return this.value; // 获取成功，返回资源值
       }
   ```

2. **共享锁（Shared Lock）**：
   ```java
   class Counter {
       private int value;
       
       // 增加计数器的值，如果当前值大于0，则获取共享锁
       public synchronized void increment() throws InterruptedException {
           while (this.value > 0) { // 如果资源已被其他线程占用，则等待
               wait(); // 调用wait()方法让当前线程进入等待状态
           }
           this.value++; // 增加计数器的值，获取共享锁
       }
       
       // 获取计数器的值，如果资源已被其他线程占用则阻塞
       public synchronized int get() throws InterruptedException {
           while (this.value == 0) { // 如果资源已被其他线程占用，则等待
               wait(); // 调用wait()方法让当前线程进入等待状态
           }
           return this.value; // 获取计数器的值，返回共享锁
       }
   }
   ```

这些示例展示了AQS在多线程环境下用于实现独占和共享锁的核心作用。