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

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

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

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

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

例如：

// 对一个对象进行同步
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);
    }
}

wait()和notify()：这些方法属于Object类，用于线程之间的通信。当一个线程处于wait状态时，它会释放对象的所有锁，并将当前线程放入可执行队列（Runnable Queue）的尾部。
synchronized blocks (Cyclic Blocks)：这与同步方法类似，但通常使用代码块形式实现同步。

举例说明如何在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("主线程结束。");
    }
}