Java多线程同步问题：互斥锁使用不当实例

原创短命女 2024-09-27 23:30 88阅读 0赞

在Java中，互斥锁（Mutex）是一种同步原语，用于控制对共享资源的访问。如果互斥锁使用不当，可能会导致死锁、活锁等问题。以下是一个互斥锁使用不当的例子：

```java
// 假设我们有一个生产者和消费者线程
class Producer extends Thread {
    private static Lock lock = new ReentrantLock();

public void run() {
        // 生产一些数据
        for (int i = 0; i < 10; i++) {
            try {
                // 使用互斥锁防止同时写入数据
                lock.lock();
                
                // 将数据写入共享缓冲区
                System.out.println("Produced: " + i);
                
                // 解除互斥锁，确保其他线程可以访问
                lock.unlock();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

class Consumer extends Thread {
    private static Lock lock = new ReentrantLock();

public void run() {
        for (int i = 0; i < 10; i++) {
            try {
                // 试图获取锁
                lock.lock();
                
                // 如果成功获取锁，打印消费数据
                System.out.println("Consumed: " + i);
                
                // 解除互斥锁，释放资源
                lock.unlock();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

// 主程序启动生产者和消费者线程
public class Main {
    public static void main(String[] args) {
        Producer producer = new Producer();
        Consumer consumer = new Consumer();

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

// 主程序在这里等待，直到所有线程完成任务
        while (producer.isAlive() || consumer.isAlive()) {
            try {
                Thread.sleep(100); // 每秒检查一次，避免CPU占用过高
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All threads finished their tasks."); // 线程任务完成后，打印提示信息
    }
}
```

在这个例子中，生产者线程尝试写入数据到共享缓冲区，但未使用互斥锁锁定资源。消费者线程在尝试读取数据时也未正确获取互斥锁。

这种情况下就会导致数据一致性问题，可能会出现消费者读到的是旧数据，而新的数据却无法被及时消费的问题。