ArrayBlockingQueue:由數組結構組成的有界阻塞隊列;java
LinkedBlockingQueue:由鏈表結構組成的有界阻塞隊列(但大小默認值爲:Integer.MAX_VALUE);數組
PriorityBlockingQueue:支持優先級排序的***阻塞隊列;ide
DelayQueue:使用優先級隊列實現的延遲***阻塞隊列;線程
SynchronousQueue:不存儲元素的阻塞隊列,也即單個元素的隊列;3d
LinkedTransferQueue:由鏈表結構組成的***阻塞隊列;blog
LinkedBlockingDeque:由鏈表結果組成的雙向阻塞隊列;排序
add(e):爲阻塞隊列添加一個元素e,添加成功返回 true,當阻塞隊列滿時,拋出異常 java.lang.IllegalStateException: Queue full隊列
remove():爲阻塞隊列移除一個元素,移除成功時返回移除的元素,當阻塞隊列爲空時,拋出異常 java.util.NoSuchElementExceptionelement
element():檢查當前阻塞隊列的首個元素,成功時返回首個元素,當阻塞隊列爲空時,拋出異常 java.util.NoSuchElementExceptionrem
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
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(); } }