并发编程(四)AbstractQueuedSynchronizer(AQS)-Semaphre源码分析跟踪

Semaphore 通常我们叫它信号量, 可以用来控制同时访问特定资源的线程数量,通过协调各个线程,以保证合理的使用资源。

  • 共享锁
  • 默认创建非公平锁

Semaphore保证的是资源的互斥而不是资源的同步,在同一时刻是无法保证同步的,但是却可以保证资源的互斥。

使用场景

  • 经常用于限制获取某种资源的线程数量(限流)
    并发编程(四)AbstractQueuedSynchronizer(AQS)-Semaphre源码分析跟踪

并发编程(四)AbstractQueuedSynchronizer(AQS)-Semaphre源码分析跟踪

emaphore常用方法说明

acquire()
获取一个令牌,在获取到令牌、或者被其他线程调用中断之前线程一直处于阻塞状态。

acquire(int permits)
获取一个令牌,在获取到令牌、或者被其他线程调用中断、或超时之前线程一直处于阻塞状态。

acquireUninterruptibly()
获取一个令牌,在获取到令牌之前线程一直处于阻塞状态(忽略中断)。

tryAcquire()
尝试获得令牌,返回获取令牌成功或失败,不阻塞线程。

tryAcquire(long timeout, TimeUnit unit)
尝试获得令牌,在超时时间内循环尝试获取,直到尝试获取成功或超时返回,不阻塞线程。

release()
释放一个令牌,唤醒一个获取令牌不成功的阻塞线程。

hasQueuedThreads()
等待队列里是否还存在等待线程。

getQueueLength()
获取等待队列里阻塞的线程数。

drainPermits()
清空令牌把可用令牌数置为0,返回清空令牌的数量。

availablePermits()
返回可用的令牌数量。

示例

public static void main(String[] args) {
    // 设置资源2个,超出后等待
    Semaphore semaphore = new Semaphore(2);
    for (int i=0;i<5;i++){
        // 开启5个线程
        new Thread(new Task(semaphore,"Semaphore Demo+"+i)).start();
    }
}

static class Task extends Thread{
    Semaphore semaphore;

    public Task(Semaphore semaphore,String tname){
        this.semaphore = semaphore;
        this.setName(tname);
    }

    public void run() {
        try {
            // 获取资源
            semaphore.acquire();
            System.out.println(Thread.currentThread().getName()+":aquire() at time:"+System.currentTimeMillis());

            // 睡眠1s
            Thread.sleep(1000);
            // 释放资源
            semaphore.release();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
}

运行结果:
并发编程(四)AbstractQueuedSynchronizer(AQS)-Semaphre源码分析跟踪

源码流程

并发编程(四)AbstractQueuedSynchronizer(AQS)-Semaphre源码分析跟踪

上一篇:并发编程(九)并发工具类CyclicBarrier,CountDownLatch,Semaphore


下一篇:Java Semaphore/CountDownLatch/CyclicBarrier 深入解析(原理篇)