java并發隊列

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

在內部，這些實現巧妙地利用了Java 1.5中引入的另一種并發功能-阻塞隊列。

隊列

首先，簡要回顧一下什么是標準隊列。 在計算機科學中，隊列只是一個集合，始終將元素添加到末尾，并且始終從頭開始獲取元素。 表達式先進先出（FIFO）通常用于描述標準隊列。 Java 1.6中引入的是Deque或雙端隊列，并且此接口現在在LinkedList上實現。 Java中的某些隊列允許其他排序，例如使用Comparator甚至編寫自己的排序實現。 盡管擴展功能很好，但是我們今天關注的是BlockingQueues如何真正在并發開發中大放異彩。

阻塞隊列

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

讓我們假設一個簡單的場景。 您有一個處理線程，其功能只是執行命令。

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);} }

當然，這是一個非常簡單的示例，但它向您展示了對多個線程使用BlockingQueue的基本知識。 讓我們嘗試一些更多的事情。 在此示例中，我們需要創建一個具有限制的連接池。 它僅應根據需要創建連接。 沒有客戶端等待超過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;}} }

最后，讓我們考慮一個有趣的實現示例示例SynchronousQueue 。

在此示例中，類似于我們的第一個示例，我們想要執行一個Command，但是需要知道它何時完成，最多等待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);} }

現在，使用者可以根據請求安全地輪詢超時，以執行其命令。

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提供了很大的靈活性，并為您提供了相對簡單的結構來滿足多線程應用程序中的許多（如果不是全部）需求。 我們甚至沒有審查過一些非常整潔的BlockingQueues ，例如PriorityBlockingQueue和DelayQueue 。 看看他們并取得聯系。 我們喜歡與開發人員交談。

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

相關文章 ：

• Java并發教程–信號量
• Java并發教程–重入鎖
• Java并發教程–線程池
• Java并發教程–可調用，將來
• Java并發教程– CountDownLatch
• Exchanger和無GC的Java
• Java Fork / Join進行并行編程
• 使用迭代器時如何避免ConcurrentModificationException
• 改善Java應用程序性能的快速技巧

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

java并發隊列

總結

以上是生活随笔為你收集整理的java并发队列_Java并发教程–阻塞队列的全部內容，希望文章能夠幫你解決所遇到的問題。

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