理解和解决Java并发问题示例

原创红太狼 2024-11-25 13:33 25阅读 0赞

Java并发问题是由于多个线程同时执行，共享资源导致的。以下提供一个理解和解决Java并发问题的示例：

1. **问题**：多个线程同时访问和修改同一个对象，可能会导致数据不一致或死锁。

2. **解决方案**：
   - **synchronized**关键字：可以使用 synchronized 关键字修饰方法或者代码块，确保同一时刻只有一个线程执行这些代码。
   - **Lock接口**：Java 14引入了 Lock 接口，它是 unsynchronized 关键字的替代。Lock 提供更细粒度的锁控制。
   - **原子操作（Atomic classes）**：Java提供了一套原子类和方法，如 AtomicInteger 和 compareAndSet 方法，可以在多线程环境下安全地进行加减运算。

3. **示例代码**：
```java
import java.util.concurrent.atomic.AtomicInteger;

public class ConcurrentExample {
    private AtomicInteger counter = new AtomicInteger(0);

public void threadSafeMethod() {
        // 创建两个线程
        Thread thread1 = new Thread(() -> incrementCounter(2)));
        Thread thread2 = new Thread(() -> decrementCounter(3)));

// 启动线程
        thread1.start();
        thread2.start();

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

private void incrementCounter(int amount) {
        counter.incrementAndGet();
    }

private void decrementCounter(int amount) {
        if (counter.getAndDec() == amount) {
            System.out.println("Counter decreased to " + amount);
        } else {
            System.out.println("Cannot decrement counter by " + amount);
        }
    }

public static void main(String[] args) {
        ConcurrentExample example = new ConcurrentExample();
        example.threadSafeMethod();
    }
}
```
在这个示例中，我们创建了一个 Counter 对象，并让两个线程同时尝试增加和减少该Counter。通过使用synchronized关键字，确保了在任何时候只有一个线程能访问Counter对象。