Guarded Suspension 设计模式

public class GuardedSuspensionQueue
{
    //定义存放 Integer 类型的 queue
    private final LinkedList<Integer> queue = new LinkedList<>();


    //定义 queue 的最大容量为100
    private final int LIMIT = 100;


    //往 queue 中插入数据，如果 queue 中的元素超过了最大容量，则会陷入阻塞
    public void offer(Integer data) throws InterruptedException
{
        synchronized (this)
        {
            //判断 queue 的当前元素是否超过了 LIMIT
            while (queue.size() >= LIMIT)
            {
                //挂起当前线程，使其陷入阻塞
                this.wait();
            }
            //插入元素并且唤醒 take 线程
            queue.addLast(data);
            this.notifyAll();
        }
    }


    //从队列中获取元素，如果队列此时为空，则会使当前线程阻塞
    public Integer take() throws InterruptedException
{
        synchronized (this)
        {
            //判断如果队列为空
            while (queue.isEmpty())
            {
                //则挂起当前线程
                this.wait();
            }
            //通知 offer 线程可以继续插入数据了
            this.notifyAll();
            return queue.removeFirst();
        }
    }
}