使用方法：

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, Runtime.getRuntime().availableProcessors() * 2, 0, TimeUnit.MILLISECONDS, new SynchronousQueue<>(), r -> new Thread(r, "ThreadTest"));
1.SynchronousQueue

SynchronousQueue沒有容量，是無緩沖等待隊列，是一個不存儲元素的阻塞隊列，會直接將任務交給消費者，必須等隊列中的添加元素被消費后才能繼續添加新的元素。

擁有公平（FIFO）和非公平(LIFO)策略，非公平側羅會導致一些數據永遠無法被消費的情況？

使用SynchronousQueue阻塞隊列一般要求maximumPoolSizes為無界，避免線程拒絕執行操作。

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, Runtime.getRuntime().availableProcessors() * 2, 0, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(), r -> new Thread(r, "ThreadTest"));
2.LinkedBlockingQueue

LinkedBlockingQueue是一個無界緩存等待隊列。當前執行的線程數量達到corePoolSize的數量時，剩余的元素會在阻塞隊列里等待。（所以在使用此阻塞隊列時maximumPoolSizes就相當于無效了），每個線程完全獨立于其他線程。生產者和消費者使用獨立的鎖來控制數據的同步，即在高并發的情況下可以并行操作隊列中的數據。

private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, Runtime.getRuntime().availableProcessors() * 2, 0, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(32), r -> new Thread(r, "ThreadTest"));
3.ArrayBlockingQueue

ArrayBlockingQueue是一個有界緩存等待隊列，可以指定緩存隊列的大小，當正在執行的線程數等于corePoolSize時，多余的元素緩存在ArrayBlockingQueue隊列中等待有空閑的線程時繼續執行，當ArrayBlockingQueue已滿時，加入ArrayBlockingQueue失敗，會開啟新的線程去執行，當線程數已經達到最大的maximumPoolSizes時，再有新的元素嘗試加入ArrayBlockingQueue時會報錯。
————————————————
版權聲明：本文為CSDN博主「無名后生」的原創文章，遵循 CC 4.0 BY-SA 版權協議，轉載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/qq_26881739/article/details/80983495

轉載于:https://www.cnblogs.com/zeenzhou/p/11573120.html

總結

以上是生活随笔為你收集整理的线程池三种队列使用,SynchronousQueue,LinkedBlockingQueue,ArrayBlockingQueue的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。