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