Java多线程同步问题：常见并发模式实践

原创太过爱你忘了你带给我的痛 2024-12-06 00:18 14阅读 0赞

在Java多线程编程中，常见的并发模式有以下几种，并且会有一些实践示例：

1. **顺序执行（Synchronized）**：
   当一个方法需要保护其内部数据一致性时，可以使用synchronized关键字。

示例代码：
   ```java
   class Counter {
       private int count;

synchronized void increment() {
           count++;
           notifyAll(); // 唤醒等待的线程
       }

public synchronized int getCount() {
           return count;
       }
   }
   ```
2. **互斥锁（Lock）**：
   Java 14引入了新的并发工具类`java.util.concurrent.locks.Lock`和`ReentrantLock`。

示例代码：
   ```java
   class Counter {
       private int count;
       private Lock lock = new ReentrantLock();

public synchronized void increment() {
           try {
               lock.acquire(); // 获取锁
               count++;
               lock.release(); // 释放锁
           } catch (InterruptedException e) {
               Thread.currentThread().interrupt();
               e.printStackTrace();
           }
       }

public synchronized int getCount() {
           return count;
       }
   }
   ```
3. **条件变量（Condition）**：
   `java.util.concurrent.locks.Condition`用于等待特定事件发生后才能执行的代码。

示例代码：
   ```java
   class Counter {
       private int count;
       private Lock lock = new ReentrantLock();
       private Condition notFull = lock.newCondition();

public synchronized void produce() {
           try {
               while (count >= 0) { // 当容器满时才触发等待
                   notFull.await(); // 等待条件变为不全（空）
                   }
               count++;
               notFull.signalAll(); // 发送信号给所有等待的线程
           } catch (InterruptedException e) {
               Thread.currentThread().interrupt();
               e.printStackTrace();
           }
       }

public synchronized void consume() {
           try {
               while (!notFull.isSignaled())) { // 当容器为空时才触发等待
                   notFull.await(); // 等待条件变为不全（空）
                   }
               count--;
               notFull.signalAll(); // 发送信号给所有等待的线程
           } catch (InterruptedException e) {
               Thread.currentThread().interrupt();
               e.printStackTrace();
           }
       }

public synchronized int getCount() {
           return count;
       }
   }
   ```
以上是Java多线程同步常见模式，你可以根据实际需求选择合适的方法。