并发控制复杂：多线程环境下Java的锁机制示例

原创待我称王封你为后i 2024-12-10 22:06 19阅读 0赞

在Java中，多线程环境下的并发控制主要通过锁机制来实现。以下是一个简单的示例：

```java
// 创建一个可共享资源（比如一个计数器）
public class Counter {
    private int count = 0;

// 提供获取和增加计数的方法
    public synchronized int getCount() {
        return count;
    }

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

// 创建两个线程，分别对计数器进行操作
public class Main {
    public static void main(String[] args) {
        Counter counter = new Counter();

// 创建并启动第一个线程（增加计数）
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                counter.increment();
                try {
                    // 线程睡眠一段时间，模拟并发操作
                    Thread.sleep(50);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

// 创建并启动第二个线程（获取计数）
        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                System.out.println("Thread 2: Count = " + counter.getCount());
                try {
                    // 线程睡眠一段时间，模拟并发操作
                    Thread.sleep(50);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }));

thread1.start();  // 启动第一个线程
        thread2.start();  // 启动第二个线程

// 等待所有线程执行完毕
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个示例中，我们创建了一个可共享资源（Counter）和两个线程。线程1负责增加计数，线程2负责获取并打印当前计数。

通过使用`synchronized`关键字来修饰方法，我们确保了在多线程环境下的并发控制，避免了数据的不一致性。