Java多线程同步问题：例子与解析

原创左手的ㄟ右手 2024-09-30 04:45 73阅读 0赞

在Java中，多线程的同步主要通过以下几个关键概念来理解和解决：

1. **锁（Lock）**：
   - `synchronized`关键字在代码块上声明锁。
   - 线程进入代码块时获取锁，执行后释放锁。
   
2. **条件变量（Condition Variable）**：
   - 除了基本的锁定，Java还提供了条件同步。
   - 线程可以等待某个特定条件满足后再继续执行。
   
3. **原子操作（Atomic Operations）**：
   - Java提供了一种方式来保证在多线程环境下的数据一致性，那就是原子操作。
   - 原子操作不会被其他线程中断，可以在无锁的环境下完成。

例子：

```java
// 示例代码：线程1获取锁后等待条件，线程2负责设置和满足条件
public class SynchronizedExample {
    private final Object lock = new Object();
    private boolean condition = false;

public void threadOne() {
        synchronized (lock) {
            // 线程1获取锁
            while (!condition) {
                // 等待条件满足
                try {
                    lock.wait(); // 释放锁，让其他线程竞争
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

// 设置或满足条件
            condition = true;
            System.out.println("Condition set in thread one"); // 输出：Condition set in thread one

// 继续执行（如打印等）
            System.out.println("Thread one continues...");

// 释放锁，允许其他线程获取
            lock.notifyAll(); 
        }
    }

public void threadTwo() {
        synchronized (lock) {
            // 设置条件为true
            condition = true;
            System.out.println("Condition set in thread two"); // 输出：Condition set in thread two

// 紧接着设置锁的信号，让等待的线程知道条件已经满足
            lock.notifyAll(); 
        }
    }

public static void main(String[] args) {
        SynchronizedExample example = new SynchronizedExample();
        Thread threadOne = new Thread(example::threadOne));
        Thread threadTwo = new Thread(example::threadTwo));

// 启动线程
        threadOne.start();
        threadTwo.start();

// 等待所有线程完成
        try {
            threadOne.join();
            threadTwo.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

这个例子展示了如何使用锁（synchronized）和条件变量（Condition Variable）来实现多线程同步。