遇到的疑惑：Java多线程同步问题实例

原创女爷i 2024-12-02 15:30 22阅读 0赞

在Java中，多线程之间的同步是非常关键的。如果没有正确的同步机制，可能会导致数据混乱、竞态条件等问题。

以下是一个简单的例子，演示了线程同步的问题：

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

public synchronized void increment() {
        count++;
        notifyAll(); // 发出信号让等待的线程唤醒
    }

public synchronized int getCount() {
        return count;
    }
}

// 创建两个线程，一个增加计数，另一个获取并打印计数
public class Main {
    private static Counter counter = new Counter();

public static void main(String[] args) {
        Thread incrementThread = new Thread(() -> {
            while (true) { // 无限循环等待机会唤醒
                try {
                    if (!counter.increment()) { // 如果计数未增加，说明有线程在执行increment操作
                        } else {
                            System.out.println("Counter incremented to " + counter.getCount()); // 获取并打印当前计数
                            break; // 结束无限循环
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        break; // 结束中断捕获的无限循环
                    }
                } catch (Exception e) {
                    System.out.println("Error occurred while incrementing counter: " + e.getMessage());
                    break; // 结束错误捕获的无限循环
                }
            }
        }));

Thread getCountThread = new Thread(() -> {
            while (true) { // 无限循环等待计数获取到后打印
                try {
                    System.out.println("Current count is: " + counter.getCount()); // 获取并打印当前计数
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        break; // 结束中断捕获的无限循环
                    }
                } catch (Exception e) {
                    System.out.println("Error occurred while retrieving count: " + e.getMessage());
                    break; // 结束错误捕获的无限循环
                }
            }
        }));

incrementThread.start(); // 启动增加计数的线程
        getCountThread.start(); // 启动获取并打印计数的线程

// 等待两个线程都执行完毕
        try {
            incrementThread.join(); // 线程A等待结束
            getCountThread.join(); // 线程B等待结束
        } catch (InterruptedException e) {
            System.out.println("Interrupted while waiting for threads to finish: " + e.getMessage());
        }
    }
}
```

在这个例子中，我们有两个共享的计数器，一个是增加计数（incrementCount方法），另一个是获取并打印当前计数（getAndPrintCount方法）。

问题在于两个线程同时运行可能导致数据不一致。在Java中，我们可以使用synchronized关键字来同步访问共享资源的线程。

上述代码中的Counter类就通过 synchronized 关键字对 increment 和 getCount 方法进行了同步。这样就可以保证在任何时候只有一个线程可以执行 increment 方法，从而避免了数据不一致的问题。