详解java中的同步工具类Semaphore

简介: Semaphore是java并发包里面的一个工具类,我们限制可以访问某些资源的线程数目就可以使用Semaphore了。这篇文章将对Semaphore的概念和使用进行一个详解。

一、概念理解


官方是这样解释的:


Semaphore用于限制可以访问某些资源(物理或逻辑的)的线程数目,他维护了一个许可证集合,有多少资源需要限制就维护多少许可证集合,假如这里有N个资源,那就对应于N个许可证,同一时刻也只能有N个线程访问。一个线程获取许可证就调用acquire方法,用完了释放资源就调用release方法。


不过这样的解释实在有点抽象,现在用我自己的话来解释一下:


相信在学生时代都去餐厅打过饭,假如有3个窗口可以打饭,同一时刻也只能有3名同学打饭。第四个人来了之后就必须在外面等着,只要有打饭的同学好了,就可以去相应的窗口了。

v2-9a262c37203391ebfcbc137899a2842f_1440w.jpg

比如说这张图,就全是了Semaphore的基本使用。认识一个知识点的最好方式就是直接去使用,我们干脆直接上代码来看看如何使用。


二、代码使用


这个案例使用的就是我们之前的小例子,也就是去餐厅打饭的案例。

我们先看Test类:

public class SemaphoreTest {
    //第一步:定义一个信号量Semaphore
    static Semaphore sp = new Semaphore(3);
    public static void main(String[] args) {
        //第二步:定义10个学生去打饭
        for(int i=0;i<10;i++) {
            //十个学生用一个信号量
            new Student(sp, "学生"+i).start();
        }
    }
}

在这个代码中我们看到,主要是new了一个Semaphore,然后赋给每一位同学Student,接下来我们就来好好看看Student线程是如何实现的。

public class Student extends Thread {
    private Semaphore sp =null;
    private String name = null;
    public Student(Semaphore sp, String name) {
        this.sp = sp;
        this.name = name;
    }
    @Override
    public void run() {
        try {
            sp.acquire();
            System.out.println(name+"拿到了打饭的许可");
            TimeUnit.SECONDS.sleep(3);  
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            System.out.println(name+"打好了饭,释放这个窗口");
            sp.release();
        }   
    }
}

在这个Student类中我们最主要看run方法的实现,首先我们通过acquire获取了当前窗口的许可,然后休眠3秒代表打饭,最后在finally使用release方法释放这个窗口许可证。代码很简单,原理很清楚,我们测试一波:

v2-18e3114aca2866a376cf63cd15ce83d9_1440w.jpg

这个结果你也看到了,基本上同一时刻只能有三个学生在窗口旁边。


在这里你可能有一个疑问了,Semaphore好像和synchronized关键字没什么区别,都可以实现同步,如果是这样那说明我们还没有真正理解jdk的注释,他只是限制了访问某些资源的线程数,其实并没有实现同步,我们可以看一下:

@Override
    public void run() {
        try {
            System.out.println(name+"进入了餐厅");
            sp.acquire();
            System.out.println(name+"拿到了打饭的许可");
            TimeUnit.SECONDS.sleep(3);  
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            System.out.println(name+"打好了饭,释放这个窗口");
            sp.release();
        }   
    }

现在我们在获取许可前增加了一条输出语句,也就是能打印出有哪个线程进入了,再去测试一波:

v2-324e9c65814e4e7a2988430a2c97ede2_1440w.jpg

结果很清晰,所以对于Semaphore来说,我们需要记住的其实是资源的互斥而不是资源的同步,在同一时刻是无法保证同步的,但是却可以保证资源的互斥。


三、其他方法


在上面我们使用最基本的acquire方法和release方法就可以实现Semaphore最常见的功能,不过其他方法还是需要我们去了解一下的。


1、acquire(int permits)


从此信号量获取给定数目的许可,在提供这些许可前一直将线程阻塞,或者线程已被中断。就好比是一个学生占两个窗口。这同时也对应了相应的release方法。


2、release(int permits)


释放给定数目的许可,将其返回到信号量。这个是对应于上面的方法,一个学生占几个窗口完事之后还要释放多少


3、availablePermits()


返回此信号量中当前可用的许可数。也就是返回当前还有多少个窗口可用。


4、reducePermits(int reduction)


根据指定的缩减量减小可用许可的数目。


5、hasQueuedThreads()


查询是否有线程正在等待获取资源。


6、getQueueLength()


返回正在等待获取的线程的估计数目。该值仅是估计的数字。


7、tryAcquire(int permits, long timeout, TimeUnit unit)


如果在给定的等待时间内此信号量有可用的所有许可,并且当前线程未被中断,则从此信号量获取给定数目的许可。


8、acquireUninterruptibly(int permits)


从此信号量获取给定数目的许可,在提供这些许可前一直将线程阻塞。

基本上常见的使用方法都在这,Semaphore底层是由AQS和Uasafe完成的,篇幅问题在这里不赘述了。感谢各位支持。

相关文章
|
2月前
|
Java 开发者
在 Java 中,一个类可以实现多个接口吗?
这是 Java 面向对象编程的一个重要特性,它提供了极大的灵活性和扩展性。
160 57
|
10天前
|
JSON Java Apache
Java基础-常用API-Object类
继承是面向对象编程的重要特性,允许从已有类派生新类。Java采用单继承机制,默认所有类继承自Object类。Object类提供了多个常用方法,如`clone()`用于复制对象,`equals()`判断对象是否相等,`hashCode()`计算哈希码,`toString()`返回对象的字符串表示,`wait()`、`notify()`和`notifyAll()`用于线程同步,`finalize()`在对象被垃圾回收时调用。掌握这些方法有助于更好地理解和使用Java中的对象行为。
|
2月前
|
存储 缓存 安全
java 中操作字符串都有哪些类,它们之间有什么区别
Java中操作字符串的类主要有String、StringBuilder和StringBuffer。String是不可变的,每次操作都会生成新对象;StringBuilder和StringBuffer都是可变的,但StringBuilder是非线程安全的,而StringBuffer是线程安全的,因此性能略低。
62 8
|
2月前
|
存储 安全 Java
java.util的Collections类
Collections 类位于 java.util 包下,提供了许多有用的对象和方法,来简化java中集合的创建、处理和多线程管理。掌握此类将非常有助于提升开发效率和维护代码的简洁性,同时对于程序的稳定性和安全性有大有帮助。
76 17
|
2月前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全,提高了并发性能。
|
2月前
|
存储 Java 程序员
Java基础的灵魂——Object类方法详解(社招面试不踩坑)
本文介绍了Java中`Object`类的几个重要方法,包括`toString`、`equals`、`hashCode`、`finalize`、`clone`、`getClass`、`notify`和`wait`。这些方法是面试中的常考点,掌握它们有助于理解Java对象的行为和实现多线程编程。作者通过具体示例和应用场景,详细解析了每个方法的作用和重写技巧,帮助读者更好地应对面试和技术开发。
137 4
|
2月前
|
Java 编译器 开发者
Java异常处理的最佳实践,涵盖理解异常类体系、选择合适的异常类型、提供详细异常信息、合理使用try-catch和finally语句、使用try-with-resources、记录异常信息等方面
本文探讨了Java异常处理的最佳实践,涵盖理解异常类体系、选择合适的异常类型、提供详细异常信息、合理使用try-catch和finally语句、使用try-with-resources、记录异常信息等方面,帮助开发者提高代码质量和程序的健壮性。
84 2
|
2月前
|
存储 安全 Java
如何保证 Java 类文件的安全性?
Java类文件的安全性可以通过多种方式保障,如使用数字签名验证类文件的完整性和来源,利用安全管理器和安全策略限制类文件的权限,以及通过加密技术保护类文件在传输过程中的安全。
66 4
|
2月前
|
Java 调度
Java 线程同步的四种方式,最全详解,建议收藏!
本文详细解析了Java线程同步的四种方式:synchronized关键字、ReentrantLock、原子变量和ThreadLocal,通过实例代码和对比分析,帮助你深入理解线程同步机制。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 线程同步的四种方式,最全详解,建议收藏!
|
2月前
|
Java Android开发
Eclipse 创建 Java 类
Eclipse 创建 Java 类
31 0