Java多线程并发编程：锁的问题实例

原创柔情只为你懂 2024-12-13 17:36 5阅读 0赞

在Java多线程编程中，锁是一种同步原语，用于控制对共享资源的访问。当多个线程同时操作一个数据时，如果没有适当的锁机制，就可能出现数据不一致或者死锁等问题。

以下是一个锁问题的实例：

```java
// 假设我们有一个共享的count变量
public class Counter {
    private int count;

public synchronized int increment() {
        count++;
        // 必须调用notifyAll()来唤醒等待这个锁的所有线程。
        notifyAll();
        return count;
    }
}

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

Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                System.out.println("Thread 1: " + counter.increment());
                // 必须让线程执行到此处，否则不会调用notifyAll()。
                try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); }
            }
        }));

Thread thread2 = new Thread(() -> {
            for (int i = 5; i < 10; i++) {
                System.out.println("Thread 2: " + counter.increment());
                // 必须让线程执行到此处，否则不会调用notifyAll()。
                try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); }
            }
        }));

thread1.start();
        thread2.start();

try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Final count: " + counter.count);
    }
}
```

在这个例子中，`Counter`类有一个共享的计数变量。每个线程都会调用`increment()`方法来增加计数。但是，如果没有锁机制，两个线程可能会同时修改计数，导致数据不一致。

在代码中，我们使用了Java的`synchronized`关键字来实现同步锁。当一个线程获得了锁后，其他线程必须等待锁被释放才能获取。这样就保证了在任何时候只有一个线程可以访问共享资源。