Java多线程同步工具：synchronized关键字及wait/notify队列示例

原创柔光的暖阳◎ 2024-11-07 08:09 9阅读 0赞

在Java中，`synchronized`关键字和`wait()`/`notify()`方法是用来实现多线程同步的常用工具。`synchronized`关键字可以用于方法或代码块，确保同一时间只有一个线程可以执行特定的代码段。而`wait()`和`notify()`方法则用于线程间的协作，它们必须在`synchronized`块或方法中使用。

下面是一个简单的示例，展示如何使用`synchronized`关键字和`wait()`/`notify()`方法来实现线程间的同步：

```javapublic class SynchronizedExample {
 private final Object lock = new Object();

public void start() {
 synchronized (lock) {
 System.out.println("Thread " + Thread.currentThread().getName() + " is running.");
//模拟长时间任务 try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
 }
 System.out.println("Thread " + Thread.currentThread().getName() + " has finished.");
lock.notify(); //通知等待的线程 }
 }

public void join() {
 synchronized (lock) {
 try {
 System.out.println("Thread " + Thread.currentThread().getName() + " is waiting.");
lock.wait(); //等待通知} catch (InterruptedException e) {
e.printStackTrace();
 }
 System.out.println("Thread " + Thread.currentThread().getName() + " has been notified.");
 }
 }

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

Thread thread1 = new Thread(() -> {
 example.start();
}, "Thread-1");

Thread thread2 = new Thread(() -> {
 example.join();
}, "Thread-2");

thread1.start();
 thread2.start();
 }
}
```在这个示例中：

1. `SynchronizedExample`类有一个`lock`对象，用于同步。
2. `start()`方法被`synchronized`关键字修饰，确保同一时间只有一个线程可以执行这个方法。
3. `join()`方法中，线程调用`lock.wait()`进入等待状态，直到被`notify()`唤醒。
4. `main`方法中创建了两个线程，`thread1`调用`start()`方法，`thread2`调用`join()`方法。

请注意，`wait()`和`notify()`方法必须在`synchronized`块或方法中使用，否则会抛出`IllegalMonitorStateException`异常。此外，`wait()`方法会释放锁，允许其他线程进入`synchronized`块，而`notify()`方法则通知一个等待的线程继续执行。