你如何理解Java中的线程同步机制？具体举例说明。

原创亦凉 2025-03-14 16:21 8阅读 0赞

在Java中，线程同步主要是通过几种同步原语（Synchronized Statements）来实现的。主要包括：

1. **synchronized关键字**：这是最常用的同步方式，它被用于方法声明或者代码块。

例如：
   ```java
   // 对一个对象进行同步
   public class MyClass {
       private int count = 0;

// 使用 synchronized 关键字
       public synchronized void increment() {
           count++;
           System.out.println("Count incremented: " + count);
       }

// 使用 synchronized 关键字，外部无法直接调用
       private synchronized void decrement() {
           count--;
           System.out.println("Count decremented: " + count);
       }
   }
   ```
2. **wait()和notify()**：这些方法属于Object类，用于线程之间的通信。当一个线程处于wait状态时，它会释放对象的所有锁，并将当前线程放入可执行队列（Runnable Queue）的尾部。

3. **synchronized blocks (Cyclic Blocks)**：这与同步方法类似，但通常使用代码块形式实现同步。

举例说明如何在Java中使用线程同步：

```java
// 假设我们有一个计数器类
public class Counter {
    private int count = 0;

// 同步方法
    public synchronized void increment() {
        count++;
        System.out.println("Count incremented: " + count);
    }

// 同步块
    private synchronized void decrement() {
        count--;
        System.out.println("Count decremented: " + count);
    }
}

// 创建两个线程，分别增加和减少计数器
public class ThreadExample {
    public static void main(String[] args) {
        Counter counter = new Counter();

// 线程1：增加计数器
        Thread threadIncrement = new Thread(() -> {
            while (true) {  // 无限循环，直到线程被中断
                counter.increment();
                try {
                    Thread.sleep(50);  // 每50毫秒执行一次
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    break;  // 线程中断，退出循环
                }
            }
        }));

// 线程2：减少计数器
        Thread threadDecrement = new Thread(() -> {
            while (true) {  // 无限循环，直到线程被中断
                counter.decrement();
                try {
                    Thread.sleep(50);  // 每50毫秒执行一次
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    break;  // 线程中断，退出循环
                }
            }
        }));

// 启动线程
        threadIncrement.start();
        threadDecrement.start();

System.out.println("主线程结束。");
    }
}
```
在这个例子中，我们创建了两个线程：一个增加计数器，另一个减少计数器。由于它们同步访问同一个Counter对象，所以不会出现数据不一致的问题。