1、保护性暂停 模式的定义

        保护性暂停 即Guarded Suspension，用于在一个线程等待另一个线程的执行结果。

要点： 

• 有一个结果需要从一个线程传递到另一个线程，让它们关联同一个对象GuardedObject。
• 如果有结果不断从一个线程到另一个线程，那么可以使用消息队列。
• JDK中，join的实现、Future的实现，采用的就是此模式。
• 因为要等待另一方的结果，因此归类到 同步模式。

 

2、代码示例

 详细的GuardedObject代码示例：

public class GuardedObject {

    // 结果
    private Object response;

    /**
     * 获取结果
     *
     * @param timeout ：表示要等待的超时时间, 单位：毫秒
     * @return Object
     */
    public Object getResponse(long timeout) {
        synchronized (this) {
            // 开始时间
            long beginTime = System.currentTimeMillis();
            // 已经等待的时间
            long passedTime = 0;

            while (response == null) {
                // 这一轮循环应该等待的时间
                long waitTime = timeout - passedTime;

                // 经历的时间超过了超时时间，则退出循环，不再等待
                if (waitTime <= 0) {
                    break;
                }

                // 等待结果
                try {
                    // 此处的wait时间为剩余的最大等待时间，如果中间被虚假唤醒，再次进入循环时，wait的等待时间会越来越小
                    this.wait(waitTime);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                // 经历的等待时间
                passedTime = System.currentTimeMillis() - beginTime;
            }
            return response;
        }
    }

    /**
     * 生成结果
     * @param response
     */
    public void generateResponse(Object response) {
        synchronized (this) {
            // 给结果成员变量赋值
            this.response = response;
            this.notifyAll();
        }
    }
}

测试代码示例：

@Slf4j
public class TestGuardedObject {

    // 线程1 等待 线程2 的结果
    public static void main(String[] args) {
        GuardedObject guardedObject = new GuardedObject();

        new Thread(() -> {
            log.debug("begin...");
            // 2000表示最多等待2秒，2秒后不论是否拿到结果，都会返回response
            Object response = guardedObject.getResponse(2000);
            log.debug("结果是：{}",response);
        },"t1").start();

        new Thread(() -> {
            log.debug("begin...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            // 生成结果
            guardedObject.generateResponse(new Object());
        },"t2").start();
    }
}

 执行结果：

15:55:42.298 [t2] DEBUG com.example.common.thread.TestGuardedObject - begin...
15:55:42.298 [t1] DEBUG com.example.common.thread.TestGuardedObject - begin...
15:55:43.311 [t1] DEBUG com.example.common.thread.TestGuardedObject - 结果是：java.lang.Object@958b770