Java多线程同步问题详解案例

原创以你之姓@ 2024-09-18 18:42 62阅读 0赞

在Java中，多线程的同步问题主要体现在共享资源的访问控制上。下面我们将通过几个典型案例来详细解释：

1. **synchronized关键字**：
   例：假设有一个全局变量count，两个线程A和B会同时修改这个值。
   ```java
   public class CountSync {
       private int count = 0;

public synchronized void increment() {
           count++;
       }

public synchronized int getCount() {
           return count;
       }
   }
   ```
   这里synchronized关键字保证了同一时刻只有一个线程能访问count变量。

2. **wait/notify/notifyAll**：
   例：一个简单的生产者消费者模型，其中两个线程分别代表生产者和消费者。
   ```java
   class Product {
       public void produce() {
           // 生产商品
       }
   }

class Consumer {
       private int count = 0;

public synchronized void consume(Product product) {
           // 消费商品并更新count
           count++;
           if (count == 10) { // 当消费完10个商品时...
               notifyAll(); // 唤醒所有等待的线程
               // 之后可以进行其他操作或关闭线程
           }
       }
   }

class Producer extends Thread {
       Product product;

public Producer(Product p) {
           product = p;
       }

@Override
       public void run() {
           try {
               for (int i = 0; i < 10; i++) {
                   product.produce(); // 生产商品并通知消费者线程
                   // 等待消费者线程确认收到商品
                   synchronized (Consumer.class) {
                       Consumer.class.wait();
                   }
               }
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
   }

public class Main {
       public static void main(String[] args) {
           Product product = new Product();
           Producer producer = new Producer(product);
           Consumer consumer = new Consumer();

// 启动生产者线程
           producer.start();

// 同时启动消费者线程和通知生产者线程
           consumer.consume(product);
           synchronized (producer) {
               producer.notifyAll();
           }

// 消费完成后，关闭消费者线程
           consumer.join();
       }
   }
```
这个例子展示了多线程同步的典型场景：生产者向多个消费者发送商品，而消费者在接收到商品后进行确认。

通过wait/notify/notifyAll机制，保证了在任何时候只有一个消费者能处理到的商品。