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

}

}

總結

以上是生活随笔為你收集整理的java 先入先出,java_阻塞队列（FIFO先进先出）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。