正文

public enum QueueTypeEnum {
    ARRAY_BLOCKING_QUEUE(1, "ArrayBlockingQueue"),
    LINKED_BLOCKING_QUEUE(2, "LinkedBlockingQueue"),
    DELAY_QUEUE(3, "DelayQueue"),
    PRIORITY_BLOCKING_QUEUE(4, "PriorityBlockingQueue"),
    SYNCHRONOUS_QUEUE(5, "SynchronousQueue"),
    LINKED_TRANSFER_QUEUE(6, "LinkedTransferQueue"),
    LINKED_BLOCKING_DEQUE(7, "LinkedBlockingDeque"),
    VARIABLE_LINKED_BLOCKING_QUEUE(8, "VariableLinkedBlockingQueue"),
    MEMORY_SAFE_LINKED_BLOCKING_QUEUE(9, "MemorySafeLinkedBlockingQueue");
}

PriorityBlockingQueue阻塞優(yōu)先隊(duì)列

一個(gè)支持優(yōu)先級排序的無界阻塞隊(duì)列；對元素沒有要求，可以實(shí)現(xiàn)Comparable接口也可以提供 Comparator來對隊(duì)列中的元素進(jìn)行比較。通過構(gòu)造函數(shù)傳入的對象來判斷，傳入的對象必須實(shí)現(xiàn)comparable接口，并重寫compareTo方法?？梢园凑?strong>自然排序或自定義排序的順序在隊(duì)列中對元素進(jìn)行排序。

例如新建對象Person:

public class Person implements Comparable<Person>{
private int id;
@Override
public int compareTo(Person person) {
        return this.id > person.getId() ? 1 : ( this.id < person.getId() ? -1 :0);
}
}

每次添加一個(gè)元素，PriorityBlockingQueue中的person都會(huì)執(zhí)行compareTo方法進(jìn)行排序，但是只是把第一個(gè)元素排在首位，其他元素按照隊(duì)列的一系列復(fù)雜算法排序。這就保障了每次獲取到的元素都是經(jīng)過排序的第一個(gè)元素。

SynchronousQueue

SynchronousQueue是一個(gè)不存儲(chǔ)元素的阻塞隊(duì)列，是BlockingQueue的一種，SynchronousQueue線程安全的。SynchronousQueue和其他的BlockingQueue不同的是SynchronousQueue的capacity是0。即SynchronousQueue不存儲(chǔ)任何元素。消費(fèi)者線程調(diào)用 take() 方法的時(shí)候就會(huì)發(fā)生阻塞，直到有一個(gè)生產(chǎn)者線程生產(chǎn)了一個(gè)元素，消費(fèi)者線程就可以拿到這個(gè)元素并返回；生產(chǎn)者線程調(diào)用 put() 方法的時(shí)候也會(huì)發(fā)生阻塞，直到有一個(gè)消費(fèi)者線程消費(fèi)了一個(gè)元素，生產(chǎn)者才會(huì)返回。

SynchronousQueue內(nèi)部并沒有數(shù)據(jù)緩存空間，你不能調(diào)用peek()方法來看隊(duì)列中是否有數(shù)據(jù)元素，因?yàn)閿?shù)據(jù)元素只有當(dāng)你試著取走的時(shí)候才可能存在，不取走而只想偷 窺一下是不行的，當(dāng)然遍歷這個(gè)隊(duì)列的操作也是不允許的。

隊(duì)列頭元素是第一個(gè)排隊(duì)要插入數(shù)據(jù)的線程，而不是要交換的數(shù)據(jù)。數(shù)據(jù)是在配對的生產(chǎn)者和消費(fèi)者線程之間直接傳遞的，并不會(huì)將數(shù)據(jù)緩沖到隊(duì)列中?？梢赃@樣來理解：生產(chǎn)者和消費(fèi)者互相等待對方，握手，然后一起離開。

SynchronousQueue的一個(gè)使用場景是在線程池里。Executors.newCachedThreadPool()就使用了SynchronousQueue，這個(gè)線程池根據(jù)需要（新任務(wù)到來時(shí)）創(chuàng)建新的線程，如果有空閑線程則會(huì)重復(fù)使用，線程空閑了60秒后會(huì)被回收?！?/p>

以上就是Java線程池隊(duì)列PriorityBlockingQueue和SynchronousQueue詳解的詳細(xì)內(nèi)容，更多關(guān)于Java線程池隊(duì)列的資料請關(guān)注腳本之家其它相關(guān)文章！