Java多线程通信问题：共享变量同步案例

原创 ╰半夏微凉° 2024-11-23 13:48 2阅读 0赞

在Java多线程编程中，当多个线程需要访问和修改一个共享变量时，就可能遇到同步问题。下面是一个简单的共享变量同步案例：

```java
// 创建一个共享变量
public class SharedVariable {
    private int count = 0;

// 提供一种方式让多个线程读取
    public synchronized int getCount() {
        return count;
    }

// 提供一种方式让多个线程增加count
    public synchronized void incrementCount() {
        count++;
    }
}

// 多个线程访问共享变量的例子
public class MultiThreadedExample {
    public static void main(String[] args) {
        // 创建一个共享变量实例
        SharedVariable shared = new SharedVariable();

// 创建两个增加count的线程
        Thread thread1 = new Thread(() -> {
            while (!shared.isCountIncremented()) {
                try {
                    Thread.sleep(50); // 模拟操作，让线程等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            shared.incrementCount(); // 增加count后释放资源
        }));

Thread thread2 = new Thread(() -> {
            while (!shared.isCountIncremented())) {
                try {
                    Thread.sleep(50); // 模拟操作，让线程等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            shared.incrementCount(); // 增加count后释放资源
        }));

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

// 确保所有资源被正确清理
        try {
            if (!shared.isCountIncremented())) {
                System.out.println("Error: Count increment not detected.");
            }
        } finally {
            shared = null; // 释放共享变量
        }
    }
}
```

在这个例子中，我们创建了一个共享变量`SharedVariable`，并为它提供了增加计数的方法。两个线程分别执行增加计数的操作，通过`synchronized`关键字保证了同步操作。最后确保所有资源被正确清理。