根據(jù)不同的需要BlockingQueue有4種具體實(shí)現(xiàn):
ArrayBlockingQueue:規(guī)定大小的BlockingQueue,其構(gòu)造函數(shù)必須帶一個(gè)int參數(shù)來(lái)指明其大小。其所含的對(duì)象是以FIFO(先入先出)順序排序的。
LinkedBlockingQueue:大小不定的BlockingQueue,若其構(gòu)造函數(shù)帶一個(gè)規(guī)定大小的參數(shù),生成的BlockingQueue有大小限制,若不帶大小參數(shù),所生成的BlockingQueue的大小由Integer.MAX_VALUE來(lái)決定。其所含的對(duì)象是以FIFO(先入先出)順序排序的。LinkedBlockingQueue和ArrayBlockingQueue比較起來(lái),它們背后所用的數(shù)據(jù)結(jié)構(gòu)不一樣,導(dǎo)致LinkedBlockingQueue的數(shù)據(jù)吞吐量要大于ArrayBlockingQueue,但在線程數(shù)量很大時(shí)其性能的可預(yù)見(jiàn)性低于ArrayBlockingQueue。
PriorityBlockingQueue:類(lèi)似于LinkedBlockingQueue,但其所含對(duì)象的排序不是FIFO,而是依據(jù)對(duì)象的自然排序順序或者是構(gòu)造函數(shù)所帶的Comparator決定的順序。
SynchronousQueue:特殊的BlockingQueue,對(duì)其的操作必須是放和取交替完成的。
下面是用BlockingQueue來(lái)實(shí)現(xiàn)Producer和Consumer的例子:
public class BlockingQueueTest {
static BlockingQueue basket;
public BlockingQueueTest() {
//定義了一個(gè)大小為2的BlockingQueue,也可根據(jù)需要用其他的具體類(lèi)
basket = new ArrayBlockingQueue(2);
}
class Producor implements Runnable {
public void run() {
while(true){
try {
//放入一個(gè)對(duì)象,若basket滿了,等到basket有位置
basket.put("An apple");
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}
}
class Consumer implements Runnable {
public void run() {
while(true){
try {
//取出一個(gè)對(duì)象,若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 原子級(jí)變量
原子量級(jí)的變量,主要的類(lèi)有AtomicBoolean, AtomicInteger, AotmicIntegerArray, AtomicLong, AtomicLongArray, AtomicReference ……。這些原子量級(jí)的變量主要提供兩個(gè)方法:
compareAndSet(expectedValue, newValue): 比較當(dāng)前的值是否等于expectedValue,若等于把當(dāng)前值改成newValue,并返回true。若不等,返回false。
getAndSet(newValue): 把當(dāng)前值改為newValue,并返回改變前的值。
這些原子級(jí)變量利用了現(xiàn)代處理器(CPU)的硬件支持可把兩步操作合為一步的功能,避免了不必要的鎖定,提高了程序的運(yùn)行效率。
8:Concurrent Collections 共點(diǎn)聚集
在Java的聚集框架里可以調(diào)用Collections.synchronizeCollection(aCollection)將普通聚集改變成同步聚集,使之可用于多線程的環(huán)境下。 但同步聚集在一個(gè)時(shí)刻只允許一個(gè)線程訪問(wèn)它,其它想同時(shí)訪問(wèn)它的線程會(huì)被阻斷,導(dǎo)致程序運(yùn)行效率不高。Java 5.0里提供了幾個(gè)共點(diǎn)聚集類(lèi),它們把以前需要幾步才能完成的操作合成一個(gè)原子量級(jí)的操作,這樣就可讓多個(gè)線程同時(shí)對(duì)聚集進(jìn)行操作,避免了鎖定,從而提高了程序的運(yùn)行效率。Java 5.0目前提供的共點(diǎn)聚集類(lèi)有:ConcurrentHashMap, ConcurrentLinkedQueue, CopyOnWriteArrayList和CopyOnWriteArraySet.
相關(guān)推薦:計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |