Java多线程同步：竞态条件示例

原创青旅半醒 2024-11-11 22:30 25阅读 0赞

在Java中，竞态条件（Race Condition）是指多个线程同时访问共享数据时，最终结果依赖于线程执行的顺序，这可能导致程序行为不可预测。下面是一个简单的Java多线程同步的竞态条件示例：

```javapublic class RaceConditionExample {
 private static int count =0;

public static void main(String[] args) {
// 创建两个线程，它们将共享count变量Thread t1 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 increment();
 }
 });

Thread t2 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 increment();
 }
 });

t1.start();
t2.start();

try {
t1.join();
t2.join();
} catch (InterruptedException e) {
e.printStackTrace();
 }

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

//一个简单的方法，用于增加count变量 private static void increment() {
 count++;
 }
}
```在这个例子中，`count`是一个共享变量，两个线程`t1`和`t2`都调用`increment()`方法来增加`count`的值。由于`increment()`方法没有同步，所以当两个线程同时执行`count++`操作时，可能会发生竞态条件。具体来说，两个线程可能会同时读取`count`的值，然后各自增加1，最后只写回一次，导致`count`的最终值比预期少了1000。

为了解决这个问题，我们可以使用`synchronized`关键字来同步`increment()`方法，确保每次只有一个线程可以执行这个方法：

```javaprivate static synchronized void increment() {
 count++;
}
```或者，我们可以使用`java.util.concurrent.atomic`包中的原子类，如`AtomicInteger`，来避免使用`synchronized`：

```javaimport java.util.concurrent.atomic.AtomicInteger;

public class RaceConditionExample {
 private static AtomicInteger count = new AtomicInteger(0);

public static void main(String[] args) {
// ...其他代码不变 ...

private static void increment() {
 count.incrementAndGet();
 }
 }
}
```使用`AtomicInteger`的`incrementAndGet()`方法可以确保`count`的增加操作是原子的，从而避免竞态条件。