Java多线程间共享数据的正确方式

原创爱被打了一巴掌 2024-09-20 13:24 41阅读 0赞

在Java中，多线程之间共享数据有多种正确的做法。这里列举几种常用的方法：

1. **静态变量（Static Fields）**：
   - 如果多个线程同时修改，可能会导致数据不一致。
   - 示例：
   ```java
   class SharedData {
       static int count = 0;
   }

// 线程A
   Thread A = new Thread(() -> {
       SharedData.count++;
   }));

// 线程B
   Thread B = new Thread(() -> {
       SharedData.count--;
   }));

A.start();
   B.start();

// 等待所有线程执行完毕
   A.join();
   B.join();

System.out.println("最终count: " + SharedData.count);
   ```
2. **使用`synchronized`关键字**：
   - 在特定的代码块上加锁，保证同一时间只有一个线程访问该块。
   - 示例：
   ```java
   class SharedData {
       int count = 0;

// 添加同步锁
       synchronized void increment() {
           count++;
       }

synchronized void decrement() {
           count--;
       }
   }

Thread A = new Thread(() -> {
       SharedData sharedData = new SharedData();
       sharedData.increment();
   }));

Thread B = new Thread(() -> {
       SharedData sharedData = new SharedData();
       sharedData.decrement();
   }));

A.start();
   B.start();

// 等待所有线程执行完毕
   A.join();
   B.join();

System.out.println("最终count: " + SharedData.count);
   ```
3. **使用`java.util.concurrent.locks.Lock`和`ReentrantLock`**：
   - Java 1.5及更高版本提供了更高级别的锁，如无条件锁（Unfair Lock）。
   - 示例（使用ReentrantLock）：
   ```java
   class SharedData {
       private int count = 0;
       private final ReentrantLock lock = new ReentrantLock();

// 添加同步锁
       public synchronized void increment() {
           lock.lock();
           try {
               count++;
           } finally {
               lock.unlock();
           }
       }

public synchronized void decrement() {
           lock.lock();
           try {
               count--;
           } finally {
               lock.unlock();
           }
       }
   }
   ```
根据实际需求和线程安全要求，可以选择上述一种或多种方式来共享数据。