外国人做外贸都会浏览哪些网站,discuz主题,马云有没有学过做网站,创建一个网站流程图JUC包下定义了一个接口#xff1a;BlockingQueue。其实现类有ArrayBlockingQueue等。本文先来介绍一下ArrayBlockingQueue。从字面可以看出#xff0c;ArrayBlockingQueue是一种基于数组的阻塞队列#xff0c;阻塞队列在线程池中会经常使用到。首先来看看ArrayBlockingQueue…JUC包下定义了一个接口BlockingQueue。其实现类有ArrayBlockingQueue等。本文先来介绍一下ArrayBlockingQueue。从字面可以看出ArrayBlockingQueue是一种基于数组的阻塞队列阻塞队列在线程池中会经常使用到。首先来看看ArrayBlockingQueue的类图如下所示。从类图可以看出ArrayBlockingQueue继承自AbstractQueue实现了BlockingQueue接口。在ArrayBlockingQueue内部有一个数组items同时定义了takeIndex和putIndex变量。由于是队列因此一端入队操作另一端进行出队操作。另外内部定义了ReentrantLock作为独占锁。1、构造函数先来看看其构造函数。其有三给构造函数不过都是调用这个构造函数。构造函数的参数需要指定初始容量同时指定采用公平锁还是非公平锁。从这一点可以看出ArrayBlockingQueue是一个有界队列。2、offer函数offer操作用于向队列尾部插入一个元素如果空闲则插入元素如果非空闲返回true。如果队列满则返回false。下面让我们来看看offer操作的源码。从上面的源码可以看出不管插入成功与否都会立即返回结果因此这个方法是非阻塞的但是也不能保证一定插入元素成功。3、put函数从源码中可以看出put操作首先检查元素是否位空如果为空则抛异常。然后进行加锁然后判断当前队列是否满了如果满了就阻塞当前线程然后挂起放入条件队列。当然这个方式是相应中断的(因为上面lockInterruptibly方法可以响应中断)。如果队列没满则入队。最后释放锁。4、poll操作poll是从队列头部取走元素其源码如下首先进行加锁操作然后判断当前队列元素是否为0如果是返回空。否则返回队列头元素。这个方法是不支持响应中断的。至于deque操作就是去数组中取元素和普通队列处理逻辑没有区别。5、take操作take操作也是从队列头取元素。其源码如下所示从源码上可以看出take也是支持响应中断的。如果队列元素为空则会阻塞挂起除非队列有元素被唤醒。也就是这个方法一定要保证取到元素如果取不到元素会等到有元素才返回。不像上面的poll方法取不到就返回null。6、peek操作peek操作时查看队列首部的元素但是不移除。源码如下从源码上可以看出此方法也是非阻塞的。即使队列没有元素也就是会立即返回的(返回null)。不像上面的take操作没有元素就等到有元素再返回。7、size操作此方法是获取队列元素个数的方法源码如下从源码可以看出size操作时加锁的因为在定义count变量的时候没有使用volitate修饰这样通过加锁保证了内存的可见性。这里其实也可以通过putIndex和takeIndex来得到队列元素长度。在Netty框架中的Bytebuf就是这样计算的。
