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();
}
}
...)
