2011年計算機等考二級JAVA學習精華整理(48)

　　根據(jù)不同的需要BlockingQueue有4種具體實現(xiàn)：

　　ArrayBlockingQueue：規(guī)定大小的BlockingQueue，其構造函數(shù)必須帶一個int參數(shù)來指明其大小。其所含的對象是以FIFO(先入先出)順序排序的。

　　LinkedBlockingQueue：大小不定的BlockingQueue，若其構造函數(shù)帶一個規(guī)定大小的參數(shù)，生成的BlockingQueue有大小限制，若不帶大小參數(shù)，所生成的BlockingQueue的大小由Integer.MAX_VALUE來決定。其所含的對象是以FIFO(先入先出)順序排序的。LinkedBlockingQueue和ArrayBlockingQueue比較起來，它們背后所用的數(shù)據(jù)結構不一樣，導致LinkedBlockingQueue的數(shù)據(jù)吞吐量要大于ArrayBlockingQueue，但在線程數(shù)量很大時其性能的可預見性低于ArrayBlockingQueue。

　　PriorityBlockingQueue：類似于LinkedBlockingQueue，但其所含對象的排序不是FIFO，而是依據(jù)對象的自然排序順序或者是構造函數(shù)所帶的Comparator決定的順序。

　　SynchronousQueue：特殊的BlockingQueue，對其的操作必須是放和取交替完成的。

　　下面是用BlockingQueue來實現(xiàn)Producer和Consumer的例子：

　　public class BlockingQueueTest {

　　static BlockingQueue basket;

　　public BlockingQueueTest() {

　　//定義了一個大小為2的BlockingQueue，也可根據(jù)需要用其他的具體類

　　basket = new ArrayBlockingQueue(2);

　　}

　　class Producor implements Runnable {

　　public void run() {

　　while(true){

　　try {

　　//放入一個對象，若basket滿了，等到basket有位置

　　basket.put("An apple");

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　}

　　class Consumer implements Runnable {

　　public void run() {

　　while(true){

　　try {

　　//取出一個對象，若basket為空，等到basket有東西為止

　　String result = basket.take();

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　}

　　public void execute(){

　　for(int i=0; i<10; i++){

　　new Thread(new Producor()).start();

　　new Thread(new Consumer()).start();

　　}

　　}

　　public static void main(String[] args){

　　BlockingQueueTest test = new BlockingQueueTest();

　　test.execute();

　　}

　　}

　　7：Atomics 原子級變量

　　原子量級的變量，主要的類有AtomicBoolean, AtomicInteger, AotmicIntegerArray, AtomicLong, AtomicLongArray, AtomicReference ……。這些原子量級的變量主要提供兩個方法：

　　compareAndSet(expectedValue, newValue): 比較當前的值是否等于expectedValue,若等于把當前值改成newValue，并返回true。若不等，返回false。

　　getAndSet(newValue): 把當前值改為newValue，并返回改變前的值。

　　這些原子級變量利用了現(xiàn)代處理器(CPU)的硬件支持可把兩步操作合為一步的功能，避免了不必要的鎖定，提高了程序的運行效率。

　　8：Concurrent Collections 共點聚集

　　在Java的聚集框架里可以調(diào)用Collections.synchronizeCollection(aCollection)將普通聚集改變成同步聚集，使之可用于多線程的環(huán)境下。 但同步聚集在一個時刻只允許一個線程訪問它，其它想同時訪問它的線程會被阻斷，導致程序運行效率不高。Java 5.0里提供了幾個共點聚集類，它們把以前需要幾步才能完成的操作合成一個原子量級的操作，這樣就可讓多個線程同時對聚集進行操作，避免了鎖定，從而提高了程序的運行效率。Java 5.0目前提供的共點聚集類有：ConcurrentHashMap, ConcurrentLinkedQueue, CopyOnWriteArrayList和CopyOnWriteArraySet.

　　　　　　　2010年9月計算機等級考試成績查詢時間匯總

 　　　　　　 2011計算機等級考試二級JAVA學習精華匯總