并发编程挑战：Java多线程下锁机制失效案例

原创川长思鸟来 2024-11-15 18:09 40阅读 0赞

在Java多线程环境中，锁机制是一个重要的同步工具。然而，在某些特定情况下，锁机制可能会失效。

以下是一个典型的失效案例：

```java
// 创建一个共享资源
public class Counter {
    private int count = 0;

// 提供原子增1的方法
    public synchronized void increment() {
        count++;
    }

// 获取当前的计数值
    public synchronized int getCount() {
        return count;
    }
}

// 创建两个线程，一个增加计数，另一个查看计数
public class ConcurrentExample {
    private Counter counter;

public ConcurrentExample(Counter counter) {
        this.counter = counter;
    }

// 线程1：增加计数
    public void incrementThread() throws InterruptedException {
        for (int i = 0; i < 1000; i++) {
            counter.increment();
        }
    }

// 线程2：查看计数
    public void viewCountThread() throws InterruptedException {
        while (!counter.getCount().equals(1000))) {
            System.out.println("Counter count: " + counter.getCount());
            Thread.sleep(100);
        }
        System.out.println("Counter count verified.");
    }

public static void main(String[] args) {
        Counter counter = new Counter();
        ConcurrentExample example = new ConcurrentExample(counter);

// 创建两个线程
        Thread incrementThread = new Thread(example::incrementThread));
        Thread viewCountThread = new Thread(example::viewCountThread));

// 启动线程
        incrementThread.start();
        viewCountThread.start();

// 确保主线程等待所有子线程完成
        incrementThread.join();
        viewCountThread.join();
    }
}
```

在这个例子中，我们创建了一个共享的Counter类，其中包含一个原子增1的方法increment()。

然后，我们创建了两个线程：incrementThread用于增加计数，viewCountThread用于查看计数。这两个线程在main方法中启动。

问题在于，由于Java并发的特性，当线程2（viewCountThread）试图获取计数值时，有可能会发现计数并未按照预期同步完成。这将导致锁机制失效的情况。