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