什么是保护性暂停模式 Guarded Suspension

👉博主介绍： 博主从事应用安全和大数据领域，有8年研发经验，5年面试官经验，Java技术专家，WEB架构师，阿里云专家博主，华为云云享专家，51CTO 专家博主

⛪️ 个人社区：个人社区
💞 个人主页：个人主页
🙉 专栏地址： ✅ Java 中级
🙉八股文专题：剑指大厂，手撕 Java 八股文

1. 什么是保护性暂停模式 Guarded Suspension

保护性暂停模式（Guarded Suspension）是一种并发设计模式，用于在多线程环境中实现线程之间的协作和同步。在这种模式中，一个线程在等待某个条件满足时会进入暂停状态，直到条件满足后再继续执行。这种模式通常用于实现生产者-消费者模式或者线程间通信。

在保护性暂停模式中，一个线程会周期性地检查一个条件（通常是一个共享的变量或对象状态），如果条件不满足，则线程会进入暂停状态等待条件满足。另外一个线程负责在条件满足时通知等待的线程，使其继续执行。

这种模式的一个常见应用是在多线程编程中使用等待-通知机制来实现线程之间的协作。通过保护性暂停模式，可以有效地管理线程之间的依赖关系，避免竞态条件和资源争用问题，确保线程安全性和数据一致性。

2. 保护性暂停模式应用场景

保护性暂停模式（Guarded Suspension）在多线程编程中有许多应用场景，以下是一些常见的应用场景：

1. 生产者-消费者模式：在生产者-消费者模式中，生产者线程生成数据并将其放入共享的队列中，而消费者线程从队列中取出数据进行处理。通过保护性暂停模式，消费者线程可以在队列为空时暂停等待，直到有数据可供消费。

2. 线程池：在线程池中，多个任务需要由线程池中的线程来执行。当线程池中的线程暂时没有可用的任务时，线程可以进入保护性暂停状态等待新的任务到来。

3. 消息队列：在消息队列系统中，生产者线程将消息发送到队列中，而消费者线程从队列中接收消息并进行处理。通过保护性暂停模式，消费者线程可以在队列为空时暂停等待新的消息到来。

4. 线程间通信：在多线程编程中，线程之间需要进行通信和协作。通过保护性暂停模式，可以实现线程之间的同步和协作，确保线程安全性和数据一致性。

总的来说，保护性暂停模式适用于任何需要线程之间协作和同步的场景，可以帮助有效管理线程之间的依赖关系，避免竞态条件和资源争用问题，提高系统的可靠性和性能。

3. 保护性暂停模式的原理

保护性暂停模式的原理是基于等待-通知机制，用于实现线程之间的协作和同步。以下是保护性暂停模式的基本原理：

1. 条件检查：在保护性暂停模式中，一个线程会周期性地检查一个条件（通常是一个共享的变量或对象状态），以确定是否满足继续执行的条件。

2. 暂停等待：如果条件不满足，线程会进入暂停状态等待条件满足。这通常通过线程的等待方法（如wait()）来实现，使线程暂停执行并释放资源。

3. 条件满足：另外一个线程负责在条件满足时通知等待的线程。这通常通过线程的通知方法（如notify()或notifyAll()）来实现，唤醒等待的线程继续执行。

4. 竞争条件处理：在线程被唤醒后，需要重新检查条件是否满足，以避免竞态条件（Race Condition）或虚假唤醒（Spurious Wakeup）等问题。

保护性暂停模式可以实现线程之间的协作和同步，确保线程在适当的时机暂停等待和继续执行。这种模式有助于避免线程之间的竞争条件和资源争用问题，提高系统的可靠性和性能。

4. 保护性暂停模式的代码案例

以下案例中，我们创建了一个生产者线程和一个消费者线程，它们通过一个共享的条件变量来进行通信和同步。

public class GuardedSuspensionExample {
    private boolean dataReady = false;

    public synchronized void waitForData() throws InterruptedException {
        while (!dataReady) {
            wait(); // 等待条件满足
        }
    }

    public synchronized void setDataReady() {
        dataReady = true;
        notify(); // 通知等待的线程
    }

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

        // 生产者线程
        Thread producerThread = new Thread(() -> {
            try {
                Thread.sleep(2000); // 模拟生产数据的耗时操作
                example.setDataReady(); // 数据准备完毕，通知消费者线程
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 消费者线程
        Thread consumerThread = new Thread(() -> {
            try {
                System.out.println("等待数据准备中...");
                example.waitForData(); // 等待数据准备
                System.out.println("收到数据，开始处理。");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        producerThread.start();
        consumerThread.start();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

生产者线程会在2秒后调用 setDataReady() 方法来通知消费者线程数据已准备好。消费者线程在调用 waitForData() 方法时会进入暂停状态等待数据准备完毕，然后收到通知后继续执行。这就展示了保护性暂停模式的基本原理。

精彩专栏推荐订阅：在下方专栏👇🏻
✅ 2023年华为OD机试真题（A卷&B卷）+ 面试指导
✅ 精选100套 Java 项目案例
✅ 面试需要避开的坑（活动）
✅ 你找不到的核心代码
✅ 带你手撕 Spring
✅ Java 初阶