并发编程：Java的线程同步问题实例

原创约定不等于承诺〃 2024-09-19 15:33 96阅读 0赞

在Java中，线程同步是通过共享资源以及特定的控制机制来实现的，以防止多个线程同时访问或修改同一资源导致数据不一致。

下面是一个简单的线程同步问题实例：

假设有一个计数器变量count，我们有三个线程：ThreadA、ThreadB和ThreadC。他们的任务是：

- ThreadA: 增加 count。
- ThreadB: 一旦 count 达到 10，立即停止所有其他线程。
- ThreadC: 检查 count 是否大于 5，并在需要时唤醒其他线程。

要解决这个问题，我们需要使用Java的synchronized关键字、wait/notify机制等。下面是一个简单的代码示例：

```java
public class CounterSync {
    private int count = 0;
    private final Object lock = new Object();

public void startThreads() {
        ThreadA threadA = new ThreadA();
        ThreadB threadB = new ThreadB(lock);
        ThreadC threadC = new ThreadC(lock);

threadA.start();
        threadB.start();
        threadC.start();
    }

// ... 实现ThreadA、ThreadB和ThreadC
}

// 线程类
class ThreadA extends Thread {
    @Override
    public void run() {
        synchronized (CounterSync.lock) {
            count++;
            System.out.println("Thread A: Count is " + count);
            // ... 适当时机释放锁
        }
    }
}

class ThreadB extends Thread {
    private final Object lock = CounterSync.lock;

@Override
    public void run() {
        synchronized (lock) {
            while (count < 10) {
                try {
                    lock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

System.out.println("Thread B: All other threads stopped.");
            // ... 适当时机释放锁
        }
    }
}

class ThreadC extends Thread {
    private final Object lock = CounterSync.lock;

@Override
    public void run() {
        synchronized (lock) {
            while (count > 5) {
                try {
                    if (count % 2 == 0) { // 偶数时唤醒
                        lock.notifyAll();
                    } else { // 奇数时继续等待
                        continue;
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

System.out.println("Thread C: Waking up other threads if needed.");
        }
    }
}
```

这个例子展示了如何使用Java的synchronized关键字和wait/notify机制来实现线程同步，以确保在多线程环境下正确地管理和更新共享资源。