Semaphore类浅析

news/2024/7/8 3:58:23 标签: semaphore

Semaphore

Semaphore，信号量。有时被称为信号灯，是在多线程环境下使用的一种设施，可以用来保证两个或多个关键代码段不被并发调用。在进入一个关键代码段之前，线程必须获取一个信号量，一旦该关键代码段完成了，那么该线程必须释放信号量，其他想进入该关键代码段的线程必须等待直到第一个线程释放信号量。

举例说明：

某广场有3个停车位，过来了6辆车，因此会有3辆车暂时没有车位，但是只要车位被空出来，这3辆车还是有机会获得车位的

Samaphore也可以用来用限流。即一次只允许有xx请求过来，多出的请求暂时等待直至被系统后续处理

构造方法摘要
`Semaphore(int permits)` 用给定的许可数和非公平的公平设置创建一个 `Semaphore`。
`Semaphore(int permits, boolean fair)` 用给定的许可数和给定的公平设置创建一个 `Semaphore`。

permits，可获得的信号量的总许可个数

fair，若信号量保证在争用时保证按着先进先出的顺序获得许可，则为true，否则false

常用方法摘要·
`acquire()` 从信号量处获得一个许可（信号量许可个数-1）
`release()` 释放一个许可至信号量（信号量许可个数+1）

Semaphore能够控制线程对某一资源的并发数量，线程通过acquire()获得一个许可，release()释放一个许可。如果被同时并发的数量已达饱和，则其他acquire()则进入等待状态，直到有线程执行完任务调用release释放许可之后，其他线程才能得到许可。

举例:

public class SemaphoreDemo {

    public static void main(String[] args) {

        Semaphore semaphore = new Semaphore(3);

        for (int i = 1; i <= 6; i++) {
            new Thread(() -> {

                try {
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "占到了车位~");
                    Thread.sleep((long) (Math.random()*1000));
                    System.out.println(Thread.currentThread().getName() + "走了，车位空出来了~");
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }, String.valueOf("线程" + i)).start();
        }


    }

}