本文主要是介绍Java并发编程-10-保护性暂挂模式在BlockingQueue源码中，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

保护性暂挂模式在BlockingQueue源码中

• 1、案例分析
• 2、源码分析
• 3、非阻塞式方法
• 4、阻塞式方法

说明：儒猿技术窝Java并发编程学习笔记

1、案例分析

我们开发这样一个服务器，它可以处理来自多个客户端的请求（即request）。为了不丢失客户端的请求，它要维护一个缓冲区，客户的请求会先储存到缓冲区，而服务器会从缓冲区中取出请求并执行，如果缓冲区没有请求，则服务器就等待，直到接收到通知有新的请求存入缓冲区

2、源码分析

使用一个基于数组的阻塞队列ArrayBlockingQueue作为缓冲区，如果缓冲区中isEmpty()没有请求，则线程进入等待状态，直到缓冲区非空时被signalAll()唤醒

ArrayBlockingQueue的父接口BlockingQueue接口位于JDK的java.util.concurrent包中，是线程安全的

3、非阻塞式方法

1.插入方法offer()：当队列元素个数与数组长度相等时，无法添加元素；如果队列已满，返回false；如果队列没有满直接添加

2.入队操作enqueue()
获取当前数组
通过putIndex索引对数组进行赋值
索引自增，如果已经是最后一个位置，重新设置putIndex=0
唤醒调用take()方法的线程，执行元素获取操作

4、阻塞式方法

1.put方法是一个阻塞方法，如果队列元素已满，那么当前线程将会被notFull condition条件对象挂起并添加到等待队列中，直到队列又重新满足notFull未满条件，即有队列元素出队了时，才会被唤醒，继续执行put添加操作。继续执行put操作。但如果队列元素本身就没有满，那么就直接调用入队enqueue(e)方法将元素加入到数组队列中

2.添加线程的执行存在一下两种情况：
队列已满：那么新到来的执行put操作的线程将被添加到notFull的条件队列中等待
队列未满：当有线程执行了移除队列元素操作，移除成功同时唤醒put线程

3.take方法执行时，队列中有元素就删除，队列为空就阻塞等待，并且时加入notEmpty条件队列等待
如果有新得线程通过put方法添加数据时，那么同时也会唤醒talke线程，即在入队方法中唤醒notEmpty condition条件等待队列中得线程移除元素操作
如果有新得线程通过take方法移除数据时，在出队方法中唤醒notFull condition条件队列中得线程，去执行插入操作

这篇关于Java并发编程-10-保护性暂挂模式在BlockingQueue源码中的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！