使用Java多线程时的同步问题示例

原创本是古典何须时尚 2024-12-01 09:06 19阅读 0赞

在Java多线程中，同步问题是由于多个线程试图访问共享资源（如变量、数组或整个对象）而发生的。如果没有适当的同步机制，就可能出现数据不一致的问题。

以下是一个简单的示例，展示了同步问题可能带来的结果：

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

// 线程1：增加计数器
    public void incrementThread1() {
        for (int i = 0; i < 1000; i++) {
            synchronized (this) { // 使用synchronized关键字同步访问count
                count++;
                System.out.println("Thread1: Count is now " + count);
            }
        }
    }

// 线程2：减少计数器
    public void decrementThread2() {
        for (int i = 0; i < 1000; i++) {
            synchronized (this) { // 同步访问count
                count--;
                System.out.println("Thread2: Count is now " + count);
            }
        }
    }
}

// 测试类，创建两个线程并调用它们的方法
public class CounterTest {
    public static void main(String[] args) {
        Counter counter = new Counter();

Thread thread1 = new Thread(() -> {
            try {
                counter.incrementThread1();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                counter.decrementThread2();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

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

// 等待所有线程执行完毕
        while (!thread1.isTerminated() && !thread2.isTerminated())) {
            try {
                Thread.sleep(100); // 每秒检查一次，实际应用中根据需要调整间隔时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("Final Count: " + counter.getCount()); // 确保在所有线程结束后获取计数器的值
    }
}
```

在这个示例中，`Counter`类有一个共享的计数器变量。两个线程（`thread1`和`thread2`）分别执行增加计数器和减少计数器的操作。

由于计数器是共享资源，所以如果没有同步机制（这里使用了`synchronized`关键字），就可能出现线程交错执行导致计数错误的问题。