java.util.concurrent 之BlockingQueue

深碍√TFBOYSˉ_ 2022-06-11 23:56 116阅读 0赞

package java.util.concurrent;
    
    import java.util.Collection;
    import java.util.Queue;
    
    public interface BlockingQueue<E> extends Queue<E> {
    
        boolean add(E e);
    
    
        boolean offer(E e);
    
    
        void put(E e) throws InterruptedException;
    
        boolean offer(E e, long timeout, TimeUnit unit)
            throws InterruptedException;
    
        E take() throws InterruptedException;
    
    
        E poll(long timeout, TimeUnit unit)
            throws InterruptedException;
    
    
        int remainingCapacity();
    
    
        boolean remove(Object o);
    
    
        public boolean contains(Object o);
    
    
        int drainTo(Collection<? super E> c);
    
    
        int drainTo(Collection<? super E> c, int maxElements);
    }

LinkedBlockingQueue是一个用链表实现的有界阻塞队列。此队列的默认和最大长度为Integer.MAX\_VALUE。   
它与ArrayBlockingQueue与使用一样，上例中可以直接用LinkedBlockingDeque替换

附：   
BlockingQueue接口常用方法：   
放入数据：

*  offer(anObject):表示如果可能的话,将anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,则返回true,否则返回false.（本方法不阻塞当前执行方法的线程）
 *  offer(E o, long timeout, TimeUnit unit),可以设定等待的时间，如果在指定的时间内，还不能往队列中加入BlockingQueue，则返回失败。
 *  put(anObject):把anObject加到BlockingQueue里,如果BlockQueue没有空间,则调用此方法的线程被阻断直到BlockingQueue里面有空间再继续.

获取数据：

*  poll(time):取走BlockingQueue里排在首位的对象,若不能立即取出,则可以等time参数规定的时间,取不到时返回null;
 *  poll(long timeout, TimeUnitunit)：从BlockingQueue取出一个队首的对象，如果在指定时间内，队列一旦有数据可取，则立即返回队列中的数据。否则知道时间超时还没有数据可取，返回失败。
 *  take():取走BlockingQueue里排在首位的对象,若BlockingQueue为空,阻断进入等待状态直到BlockingQueue有新的数据被加入;
 *  drainTo():一次性从BlockingQueue获取所有可用的数据对象（还可以指定获取数据的个数），通过该方法，可以提升获取数据效率；不需要多次分批加锁或释放锁。