营销网站建设的价格,电厂cms系统是什么,计算机培训班学什么,单页网站开发这是我们将要进行的Java并发系列的第一部分。 具体来说#xff0c;我们将深入探讨Java 1.5及更高版本中内置的并发工具。 我们假设您对同步和易失性关键字有基本的了解。 第一篇文章将介绍信号量-特别是对信号量进行计数 。 信号量是用于限制对资源访问的经常被误解和使用不足… 这是我们将要进行的Java并发系列的第一部分。 具体来说我们将深入探讨Java 1.5及更高版本中内置的并发工具。 我们假设您对同步和易失性关键字有基本的了解。 第一篇文章将介绍信号量-特别是对信号量进行计数 。 信号量是用于限制对资源访问的经常被误解和使用不足的工具。 对于其他控制对资源的访问的方式它们将被忽略。 但是信号量为我们提供了一个超越常规同步和其他工具所能提供的工具集的工具集。 那么什么是信号量 想到信号量的最简单方法是将其视为允许n个单位被获取并提供获取和释放机制的抽象。 它安全地允许我们确保在给定的时间只有n个进程可以访问特定资源 。 一切都很好但是这将达到什么目的呢 好吧这是一个示例将有助于解释其用法。 它使用位于1.5。中的java.util.concurrent包中精心设计的Semaphore类。 限制连接 也许我们有一个过程可以通过HTTP定期为我们下载资源。 我们不想向任何主机发送垃圾邮件同时我们想限制正在建立的连接数因此我们不会耗尽允许的有限文件句柄或出站连接。 一种简单的方法是使用信号量 public class ConnectionLimiter {private final Semaphore semaphore;private ConnectionLimiter(int maxConcurrentRequests) {semaphore new Semaphore(maxConcurrentRequests);}public URLConnection acquire(URL url) throws InterruptedException,IOException {semaphore.acquire();return url.openConnection();}public void release(URLConnection conn) {try {/** ... clean up here*/} finally {semaphore.release();}}
} 对于资源有限的问题这是一个很好的解决方案。 对acquire的调用将阻塞直到获得许可为止。 信号灯的优点在于它隐藏了管理访问控制计算许可数以及确保正确的线程安全性的所有复杂性。 危险性 与大多数锁定或同步方法一样存在一些潜在问题。 要记住的第一件事是 始终释放您获得的东西 。 这是通过使用try..finally构造完成的。 使用信号量时还有其他不太明显的问题可能会降临您。 以下课程显示了死锁只有您中最幸运的人才能避免。 您会注意到获得两个信号量许可的两个线程的执行顺序相反。 为简洁起见try..finally最终被省去了。 public static void main(String[] args) throws Exception {Semaphore s1 new Semaphore(1);Semaphore s2 new Semaphore(1);Thread t new Thread(new DoubleResourceGrabber(s1, s2));// now reverse them ... here comes trouble!Thread t2 new Thread(new DoubleResourceGrabber(s2, s1));t.start();t2.start();t.join();t2.join();System.out.println(We got lucky!);
}private static class DoubleResourceGrabber implements Runnable {private Semaphore first;private Semaphore second;public DoubleResourceGrabber(Semaphore s1, Semaphore s2) {first s1;second s2;}public void run() {try {Thread t Thread.currentThread();first.acquire();System.out.println(t acquired first);Thread.sleep(200); // demonstrate deadlocksecond.acquire();System.out.println(t acquired second);second.release();System.out.println(t released second);first.release();System.out.println(t released first);} catch (InterruptedException ex) {ex.printStackTrace();}}
} 如果运行此程序则很有可能会挂起一个进程。 锁排序的问题与Java中的常规互斥锁或同步一样也适用于信号量。 在某些情况下超时请参阅本文后面的tryAcquire注释可用于防止死锁导致进程挂起但是死锁通常是可以避免的逻辑错误的征兆。 如果您不熟悉死锁建议您仔细阅读它们。 维基百科上有一篇关于死锁的文章该文章同样适用于所有语言。 使用信号量包括二进制信号量即互斥体时应注意的主要事项是 获取后不释放丢失的释放调用或引发异常并且没有finally块 长时间保持信号量导致线程饥饿 死锁如上所示 有用的信号灯技巧 Java中Semaphores的一个有趣的特性是 不必通过与Acquisition相同的线程来调用release 。 这意味着您可以具有一个线程限制器该线程限制器可以通过调用acquire来基于信号量池或创建线程。 然后正在运行的线程可以在完成时释放其自己的信号灯许可。 这是Java中普通互斥锁所没有的有用属性。 另一个技巧是在运行时增加许可数量 。 与您可能会猜到的相反信号量中的许可数量不是固定的并且即使未进行相应的acquire调用对release的调用也会始终增加许可的数量。 请注意如果在没有进行acquire的情况下错误地调用release 这也会导致错误。 最后在Java的Semaphore中有一些有用的方法要熟悉。 方法AcquireInterruptible将获取资源如果资源被中断则重新尝试。 这意味着没有对InterruptedException的外部处理。 tryAcquire方法允许我们限制等待许可的时间-我们可以在没有许可的情况下立即返回也可以等待指定的超时时间。 如果您以某种方式知道了无法轻松修复或跟踪的死锁则可以通过使用带有适当超时的tryAcquire来帮助防止锁定进程。 用途 计数信号量有哪些可能的用途 请注意以下几点 限制对磁盘的并发访问由于竞争磁盘搜寻这可能会降低性能 线程创建限制 JDBC连接池/限制 网络连接限制 限制CPU或内存密集型任务 当然信号量是访问控制和同步的一个很底层的构建块。 Java为我们提供了Java 1.5及更高版本中引入的大量并发机制和策略。 在接下来的文章中我们将介绍一些更抽象的并发管理方法包括执行器BlockingQueuesBarriersFuture以及一些新的并发Collection类。 您发现信号量有什么用途 通过发表评论让我们知道–我们喜欢语音软件。 参考 Java并发第1部分–来自我们的JCG合作伙伴的信号灯 在Carfey Software博客上 。 相关文章 Java并发教程–重入锁 Java并发教程–线程池 Java并发教程–可调用将来 Java并发教程–阻塞队列 Java并发教程– CountDownLatch Exchanger和无GC的Java Java Fork / Join进行并行编程 Java最佳实践–队列之战和链接的ConcurrentHashMap 如何在不到1ms的延迟内完成100K TPS 使用迭代器时如何避免ConcurrentModificationException 改善Java应用程序性能的快速技巧 相关片段 阻塞队列示例以执行命令 限制URL连接的信号量示例 执行命令的同步队列示例 更一般的等待/通知机制的CountDownLatch示例 翻译自: https://www.javacodegeeks.com/2011/09/java-concurrency-tutorial-semaphores.html
