java_阻塞隊列(FIFO先進先出)

java_阻塞隊列(FIFO先進先出)

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

 

 

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

相關文章
相關標籤/搜索