Java多线程：阻塞与唤醒的实例分析

原创偏执的太偏执、 2024-10-14 11:06 49阅读 0赞

在Java多线程编程中，阻塞与唤醒是两个重要的概念。下面我们将通过一个具体的实例来深入理解。

**实例：生产者-消费者模型**

1. **创建线程类**（生产者和消费者）

```java
public class ThreadExample {
    private int count = 0;

// 生产者线程
    public void producerThread() {
        for (int i = 0; i < 5; i++) {
            synchronized (this) {
                count++;
                System.out.println("Producer: Count " + count);

// 如果count达到特定值，唤醒消费者线程
                if (count >= 10) {
                    this.notifyAll();
                }
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        while (true) {
            synchronized (this) {
                // 等待生产者创建计数到10的条件
                if (count < 10) {
                    this.wait();
                } else {
                    System.out.println("Consumer: Count " + count);

// 如果计数达到10，生产者线程将唤醒消费者
                    if (count == 10) {
                        this.notifyAll();
                    }
                }
            }
        }
    }

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

// 创建生产者线程并启动
        Thread producerThread = new Thread(example::producerThread));
        producerThread.start();

// 创建消费者线程并启动
        Thread consumerThread = new Thread(example::consumerThread));
        consumerThread.start();
    }
}
```

在这个例子中，生产者负责创建和增加计数器。当计数达到10时，它会调用`notifyAll()`方法唤醒消费者。

消费者则会在等待阶段被唤醒，并开始检查当前的计数值。如果计数小于10，消费者就会继续等待；否则，消费者就会打印当前的计数值并进入下一个循环等待生产者的唤醒。