商业网站建设案例课程 下载,工信部企业网站认证,centos打开wordpress,dede企业网站如第3部分所述#xff0c;Java 1.5中引入的线程池提供了核心支持#xff0c;该支持很快成为许多Java开发人员的最爱。 在内部#xff0c;这些实现巧妙地利用了Java 1.5中引入的另一种并发功能-阻塞队列。 队列 首先#xff0c;简要回顾一下什么是标准队列。 在计算机科学… 如第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 BlockingQueueCommand workQueue new LinkedBlockingQueueCommand();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 BlockingQueueConnection pool new ArrayBlockingQueueConnection(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
