SynchronousQueue

A synchronous queue does not have any internal capacity, not even a capacity of one
synchronous queue 

這個隊列沒有容量,一條也沒有。
基于生產(chǎn)者-消費者模式,可實現(xiàn)同步阻塞的功能。
生產(chǎn)者生產(chǎn)數(shù)據(jù)后,如果沒有消費者進行消費,那么生產(chǎn)者線程將會阻塞,直到有消費者消費數(shù)據(jù)。
如果消費者要消費數(shù)據(jù),但是沒有生產(chǎn)者生產(chǎn)數(shù)據(jù),那么消費者線程將阻塞,直到有生產(chǎn)者生產(chǎn)數(shù)據(jù)。

應用:
Executors.newCachedThreadPool

public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>(),
                                      threadFactory);
    }

緩存線程池,不會有任務在隊列里面。新的任務會直接去獲取線程,若沒有線程可用,則創(chuàng)建線程,直到Integer最大值2^31-1。若線程數(shù)已達到最大值且還有任務進來,將進行拒絕處理。

?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容