线程池任务队列

深碍√TFBOYSˉ_ 2024-03-17 10:55 71阅读 0赞

***`runnableTaskQueue`***（任务队列）：用于保存等待执行的任务的 ***`阻塞队列`*** 。可以选择以下几个阻塞队列。

<table> 
 <thead> 
 <tr> 
 <th align="left">阻塞队列</th> 
 <th align="left">解释</th> 
 <th align="left">补充</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td align="left"><code>ArrayBlockingQueue</code></td> 
 <td align="left">一个由数组结构组成的有界阻塞队列</td> 
 <td align="left">FIFO 创建一个公平的阻塞队列 <code>ArrayBlockingQueue fairQueue = new ArrayBlockingQueue(1000,true);</code> 创建一个非公平的阻塞队列 <code>ArrayBlockingQueue fairQueue = new ArrayBlockingQueue(1000);</code> </td> 
 </tr> 
 <tr> 
 <td align="left"><code>LinkedBlockingQueue</code></td> 
 <td align="left">一个由链表结构组成的有界阻塞队列</td> 
 <td align="left">FIFO 此队列的 默认 和 最大长度 为<code>Integer.MAX_VALUE</code></td> 
 </tr> 
 <tr> 
 <td align="left"><code>SynchronousQueue</code></td> 
 <td align="left">一个不存储元素的阻塞队列</td> 
 <td align="left">每一个<code>put</code>操作必须等待一个<code>take</code>操作，否则不能继续添加元素。 默认情况下线程采用非公平性策略访问队列。 <code>SynchronousQueue unfair = new SynchronousQueue();</code> 使用构造方法SynchronousQueue(true)创建公平性访问的<code>SynchronousQueue</code>，则等待的线程会采用先进先出的顺序访问队列。 <code>SynchronousQueue fair = new SynchronousQueue(true);</code> <code>SynchronousQueue</code>可以看成是一个传球手，负责把生产者线程处理的数据直接传递给消费者线程。队列本身并不存储任何元素，非常适合传递性场景。</td> 
 </tr> 
 <tr> 
 <td align="left"><code>PriorityBlockingQueue</code></td> 
 <td align="left">一个支持优先级排序的无界阻塞队列</td> 
 <td align="left">默认情况下元素采取自然顺序升序排列。也可以自定义。 需要注意的是不能保证同优先级元素的顺序。</td> 
 </tr> 
 </tbody> 
</table>

--------------------

### 吞吐量 ###

`SynchronousQueue` > `LinkedBlockingQueue` > `ArrayBlockingQueue`

--------------------

### Read More ###

[Java中的阻塞队列][Java]

\-----------------------------------------------------------------------------摘自 书名：Java并发编程的艺术 作者：方腾飞；魏鹏；程晓明

[Java]: https://blog.csdn.net/weixin_37646636/article/details/130855714