java_阻塞队列（FIFO先进先出）

java_阻塞队列（FIFO先进先出）

ArrayBlockingQueue：由数组结构组成的有界阻塞队列；

LinkedBlockingQueue：由链表结构组成的有界阻塞队列（但大小默认值为：Integer.MAX_VALUE）；

PriorityBlockingQueue：支持优先级排序的***阻塞队列；

DelayQueue：使用优先级队列实现的延迟***阻塞队列；

SynchronousQueue：不存储元素的阻塞队列，也即单个元素的队列；

LinkedTransferQueue：由链表结构组成的***阻塞队列；

LinkedBlockingDeque：由链表结果组成的双向阻塞队列；

 

阻塞队列核心方法

add(e)：为阻塞队列添加一个元素e，添加成功返回 true，当阻塞队列满时，抛出异常 java.lang.IllegalStateException: Queue full

remove()：为阻塞队列移除一个元素，移除成功时返回移除的元素，当阻塞队列为空时，抛出异常 java.util.NoSuchElementException

element()：检查当前阻塞队列的首个元素，成功时返回首个元素，当阻塞队列为空时，抛出异常 java.util.NoSuchElementException

 

offer(e)：为阻塞队列添加一个元素e，添加成功返回 true，当阻塞队列满时返回 false

poll()：为阻塞队列移除一个元素，移除成功时返回移除的元素，当阻塞队列为空时，返回 null

peek()：检查当前阻塞队列的首个元素，成功时返回首个元素，当阻塞队列为空时，返回 null

 

put(e)：为阻塞队列添加一个元素e，无返回值，当阻塞队列满时会阻塞线程，直到操做成功为止

take()：为阻塞队列移除一个元素，成功时返回首个元素，当阻塞队列为空时会阻塞线程，直到操做成功为止

 

offer(e,time,unit)：为阻塞队列添加一个元素e，添加成功返回 true，当阻塞队列满时会阻塞队列一段时间（time：long类型的时间，unit为时间单位），失败返回 false

poll(time,unit)：为阻塞队列移除一个元素，移除成功时返回移除的元素，当阻塞队列为空时，会阻塞队列一段时间（time：long类型的时间，unit为时间单位），失败返回  null

 

 

SynchronousQueue：不存储元素的阻塞队列

public class SynchronousQueueDemo {public static void main(String[] args) {
        BlockingQueue queue = new SynchronousQueue<>();new Thread(() ->{try {
                System.out.println(Thread.currentThread().getName()+"\t put 1");
                queue.put(1);
                System.out.println(Thread.currentThread().getName()+"\t put 2");
                queue.put(2);
                System.out.println(Thread.currentThread().getName()+"\t put 3");
                queue.put(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"A").start();new Thread(() ->{try {try { TimeUnit.SECONDS.sleep(3); }catch (Exception e){ e.printStackTrace(); }
                System.out.println(Thread.currentThread().getName()+"\t"+queue.take());try { TimeUnit.SECONDS.sleep(3); }catch (Exception e){ e.printStackTrace(); }
                System.out.println(Thread.currentThread().getName()+"\t"+queue.take());try { TimeUnit.SECONDS.sleep(3); }catch (Exception e){ e.printStackTrace(); }
                System.out.println(Thread.currentThread().getName()+"\t"+queue.take());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"B").start();
    }
}