频繁出现：Java多线程同步问题实例

原创小鱼儿 2024-09-19 12:03 63阅读 0赞

在Java编程中，多线程同步问题是常见的挑战之一。以下是一些关于Java多线程同步问题的实例：

1. **互斥锁（Mutex）**：
   ```java
   Lock lock = new ReentrantLock();
   
   // 多个线程同时进入临界区
   synchronized (lock) {
       // 在这里完成需要保护的操作
   }
   ```
2. **条件变量（Condition）**：
   ```java
   // 假设我们有一个生产者和消费者模型
   Queue<Integer> queue = new ArrayQueue<>();
   Condition notEmpty = new ReentrantCondition();
   
   // 生产者线程
   Thread producer = new Thread(() -> {
       while (true) {  // 无尽循环
           int item = Math.random();  // 生成随机数
           queue.add(item);
           notEmpty.signalAll();  // 通知所有等待的线程
       }
   }));
   
   // 消费者线程
   Thread consumer = new Thread(() -> {
       while (true) {  // 无尽循环
           if (!queue.isEmpty()) {
               int item = queue.poll();
               System.out.println("Consumed: " + item);
               notEmpty.signalAll();  // 通知所有等待的线程
           }
       }
   }));
   
   producer.start();
   consumer.start();
   ```

3. **Semaphore（信号量）**：
   ```java
   Semaphore semaphore = new Semaphore(1);  // 初始化为允许一个线程进入

// 示例：多个线程同时尝试访问某个资源
   class AccessResourceTask implements Runnable {
       @Override
       public void run() {
           try {
               semaphore.acquire();  // 请求进入资源的许可
               System.out.println("Access granted to resource!");  // 资源访问成功
               semaphore.release();  // 释放已经获取的许可，允许其他线程进入
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       }
   }

Thread task1 = new Thread(new AccessResourceTask()));
   Thread task2 = new Thread(new AccessResourceTask()));

task1.start();
   task2.start();
   ```

以上实例展示了在Java多线程环境中，如何使用锁（互斥锁）、条件变量和信号量来实现同步。