如第3部分所述，Java 1.5中引入的線程池提供了核心支持，該支持很快成為許多Java開發(fā)人員的最愛。

在內(nèi)部，這些實(shí)現(xiàn)巧妙地利用了Java 1.5中引入的另一種并發(fā)功能-阻塞隊(duì)列。

隊(duì)列

首先，簡(jiǎn)要回顧一下什么是標(biāo)準(zhǔn)隊(duì)列。 在計(jì)算機(jī)科學(xué)中，隊(duì)列只是一個(gè)集合，始終將元素添加到末尾，并始終從頭開始獲取元素。 表達(dá)式先進(jìn)先出（FIFO）通常用于描述標(biāo)準(zhǔn)隊(duì)列。 在Java 1.6中引入的是Deque或雙端隊(duì)列，該接口現(xiàn)在在LinkedList上實(shí)現(xiàn)。 Java中的某些隊(duì)列允許其他排序，例如使用Comparator甚至編寫自己的排序?qū)崿F(xiàn)。 雖然擴(kuò)展功能很好，但是我們今天關(guān)注的是BlockingQueues如何真正在并發(fā)開發(fā)中大放異彩。

阻塞隊(duì)列

阻塞隊(duì)列是一些隊(duì)列，它們還公開了在沒有可用元素的情況下阻止檢索元素的請(qǐng)求的功能，該附加選項(xiàng)可以限制等待時(shí)間。 在受限制的大小隊(duì)列上，嘗試添加時(shí)可以使用相同的阻止功能。 讓我們深入探討一下BlockingQueue用法的示例。

讓我們假設(shè)一個(gè)簡(jiǎn)單的場(chǎng)景。 您有一個(gè)處理線程，其功能只是執(zhí)行命令。

import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue;private BlockingQueue<Command> workQueue = new LinkedBlockingQueue<Command>();public void addCommand(Command command) {workQueue.offer(command); }public Object call() throws Exception {try {Command command = workQueue.take();command.execute();} catch (InterruptedException e) {throw new WorkException(e);} }

當(dāng)然，這是一個(gè)非常簡(jiǎn)單的示例，但它向您展示了對(duì)多個(gè)線程使用BlockingQueue的基本知識(shí)。 讓我們嘗試一些更多的事情。 在此示例中，我們需要?jiǎng)?chuàng)建一個(gè)具有限制的連接池。 它僅應(yīng)根據(jù)需要?jiǎng)?chuàng)建連接。 沒有客戶端將等待超過5秒的可用連接。

private BlockingQueue<Connection> pool = new ArrayBlockingQueue<Connection>(10); private AtomicInteger connCount = new AtomicInteger();public Connection getConnection() {Connection conn = pool.poll(5, TimeUnit.SECONDS);if (conn == null) {synchronized (connCount) {if (connCount.get() < 10) {conn = getNewConnection();pool.offer(conn);connCount.incrementAndGet();}}if (conn == null) {throw new ConnUnavailException();} else {return conn;}} }

最后，讓我們考慮一個(gè)有趣的實(shí)現(xiàn)示例示例SynchronousQueue 。

在此示例中，類似于我們的第一個(gè)示例，我們想要執(zhí)行一個(gè)Command，但是需要知道它何時(shí)完成，最多等待2分鐘。

private BlockingQueue workQueue = new LinkedBlockingQueue(); private Map commandQueueMap = new ConcurrentHashMap(); public SynchronousQueue addCommand(Command command) {SynchronousQueue queue = new SynchronousQueue();commandQueueMap.put(command, queue);workQueue.offer(command);return queue; }public Object call() throws Exception {try {Command command = workQueue.take();Result result = command.execute();SynchronousQueue queue = commandQueueMap.get(command);queue.offer(result);return null;} catch (InterruptedException e) {throw new WorkException(e);} }

現(xiàn)在，使用者可以安全地輪詢其請(qǐng)求以執(zhí)行其命令的超時(shí)。

Command command; SynchronousQueue queue = commandRunner.addCommand(command); Result result = queue.poll(2, TimeUnit.MINUTES); if (result == null) {throw new CommandTooLongException(command); } else {return result; }

正如您開始看到的那樣，java中的BlockingQueues提供了很大的靈活性，并為您提供了相對(duì)簡(jiǎn)單的結(jié)構(gòu)來滿足多線程應(yīng)用程序中的許多（如果不是全部）需求。 我們甚至沒有審查過一些非常整潔的BlockingQueues ，例如PriorityBlockingQueue和DelayQueue 。 看看他們并取得聯(lián)系。 我們喜歡與開發(fā)人員交談。

參考： Carfey Software博客上的JCG合作伙伴的Java并發(fā)第5部分-阻塞隊(duì)列 。

相關(guān)文章 ：

• Java并發(fā)教程–信號(hào)量
• Java并發(fā)教程–重入鎖
• Java并發(fā)教程–線程池
• Java并發(fā)教程–可調(diào)用，將來
• Java并發(fā)教程– CountDownLatch
• Exchanger和無GC的Java
• Java Fork / Join進(jìn)行并行編程
• 使用迭代器時(shí)如何避免ConcurrentModificationException
• 改善Java應(yīng)用程序性能的快速技巧

翻譯自: https://www.javacodegeeks.com/2011/09/java-concurrency-tutorial-blocking.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的Java并发教程–阻塞队列的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。