阻塞队列

女爷i 2022-02-04 22:37 237阅读 0赞

BlockingQueue是一个继承自Queue的接口，在Queue的队列基础上增加了阻塞操作，在BlockingQueue为空时从队头取数据将会被阻塞，因为此时还没有数据可取，一旦队列中有数据了，取数据的线程就会释放得到了数据，如果BlockingQueue有容量限制且满了，那么插入数据的线程将会阻塞，直到队列中有空闲位置可以插入数据了才会释放

***Queue接口方法：***  
        **add(e)入队        remove()出队    element()检索    在执行方法失败时不返回值，抛出异常  
        offer(e)入队    poll()出队        peek()检索        在执行方法失败时返回false或者null**  
    BlockingQueue接口新增方法：  
       ** put(e)阻塞入队        E take()阻塞出队    offer(e,time,unit)定时入队    E poll(time,unit)定时出队**

***BlockingQueue接口实现：***  
        ArrayBlockingQueue：一个基于数组实现的有界阻塞队列，必须设置容量，基于ReentrantLock的newCondition实现的，其中Condition notEmpty（Condition for waiting takes），Condition notFull（Condition for waiting puts）  
        LinkedBlockingQueue：一个基于链表实现的有界阻塞队列，默认长度为Integer.MAX\_VALUE，容量可以选择进行设置，同样基于ReentrantLock的newCondition实现的，不同的是读和写是分开加锁的  
        PriorityBlockingQueue： 一个支持优先级的无界阻塞队列，它可以对元素进行排序，我们可以指定一个实现了Comparator的比较器  
        DelayQueue：一个支持延时获取元素的无界阻塞队列，队列使用PriortiyQueue来实现，队列中的元素必须实现Delayed接口，在创建元素的时候，可以指定多久才能从队列获取当前元素，只有在延迟期满时才能从队列中提取元素  
        SynchrousQueue：一个不存储元素的阻塞队列，每一个put操作必须等一个take操作，否则不能继续添加元素，即直接将接到的元素传给其他使用者  
        LinkedBlockingDeque： 一个基于双端链表的双向阻塞队列，即可以从两端插入和移除元素，双向队列因为多了一个操作队列的入口，在多线程同时入队列，也就减少了一半的竞争，相比其他的阻塞队列多了addFirst、offerFirst、offerLast、PeekFirst、peekLast方法