Semaphore实现Andoird版源代码剖析

Semaphore是一个计数的信号量。从概念上来说,信号量维持一组许可(permits)。acquire方法在必须的时候都会堵塞直到有一个许可可用,然后就会拿走这个许可。release方法加入一个许可,会有可能释放一个堵塞中的获取者(acquirer)。然而,Semaphore没有使用真实的许可对象,仅仅是保持一个可用计数而且採取对应的行为。

信号量一般用于限制能够訪问一些(物理上或者逻辑上)的资源的并发线程数。

信号量初始化为1的时候,意味着它最多仅仅有一个同意可用,这样就能作为相互排斥独占锁使用。这样的很多其它地被称为二进制信号量(binary semaphore),由于它仅仅有两个状态:一个许可可用,或者0个许可可用。当使用这样的方式的时候,二进制信号量就有这样的属性(不像大部分锁的实现):锁能够被拥有者(就如信号量没有拥有者的概念)之外的另外线程释放。这样的属性在某些特殊的上下文中非常实用,比如死锁恢复。

类的构造函数可选地接受一个fairness參数。当设为false的时候,该类就不会保证线程获取许可的顺序。特别地,插队是同意的,也就是说,线程调用acquire方法能够在另外的等待线程之前分配许可————逻辑上新线程会把自己放在等待线程队列头。当fairness设为true,信号量就保证调用acquire方法的线程会以它们调用方法的处理顺序来获取许可(FIFO)。注意FIFO的顺序决定特指在这些方法的内部运行点。因此,有可能一条线程在另外一条线程之前调用了acquire方法,但实际顺序会在另外一条线程之后,相同也适用于函数返回的先后顺序。相同要注意非超时版本号tryAcquire方法不会遵循fairness设置,会立即获取不论什么可用的许可。

一般来说,信号量用来控制资源訪问的话,就应该被初始化为公平(fairness设为true),这样能够确保没有线程会在訪问资源的时候饿坏。当使用在其它同步控制的情况下使用信号量,非公平的吞吐量优势一般优于公平的考虑。

事实上整体上来看,fairness參数以及状态量的概念非常接近AQS(AbstractQueuedSynchronizer)提供的功能,因此大家也应该猜到Semaphore的内部实现也是通过一个继承AQS的内部类实现接口功能。接下来我们细致看看内部的实现。

详细实现

先来看看Semaphore的构造函数:

    public Semaphore(int permits) {
        sync = new NonfairSync(permits);
    }

    public Semaphore(int permits, boolean fair) {
        sync = fair ? new FairSync(permits) : new NonfairSync(permits);
    }

能够看到构造函数与ReentrantLock实现类似,都是依照fair參数分配创建不同的锁类,再来看看Semaphore的acquire和release的接口实现

    public void acquire() throws InterruptedException {
        sync.acquireSharedInterruptibly(1);
    }

    public void release() {
        sync.releaseShared(1);
    }

能够看到acquire和release的实现都是调用内部类Sync的方法实现,当然了,这些方法也就是AQS提供出来的获取和释放共享锁接口。接下来看看整个实现里最基本的内部类Sync的相关实现:

    abstract static class Sync extends AbstractQueuedSynchronizer {
        private static final long serialVersionUID = 1192457210091910933L;

        Sync(int permits) {
            setState(permits);
        }

        final int nonfairTryAcquireShared(int acquires) {
            for (;;) {
                int available = getState();
                int remaining = available - acquires;
                if (remaining < 0 ||
                    compareAndSetState(available, remaining))
                    return remaining;
            }
        }

        protected final boolean tryReleaseShared(int releases) {
            for (;;) {
                int current = getState();
                int next = current + releases;
                if (next < current) // overflow
                    throw new Error("Maximum permit count exceeded");
                if (compareAndSetState(current, next))
                    return true;
            }
        }

        //省略一些次要方法
    }

    /**
     * 非公平版本号
     */
    static final class NonfairSync extends Sync {
        private static final long serialVersionUID = -2694183684443567898L;

        NonfairSync(int permits) {
            super(permits);
        }

        protected int tryAcquireShared(int acquires) {
            return nonfairTryAcquireShared(acquires);
        }
    }

    /**
     * 公平版本号
     */
    static final class FairSync extends Sync {
        private static final long serialVersionUID = 2014338818796000944L;

        FairSync(int permits) {
            super(permits);
        }

        protected int tryAcquireShared(int acquires) {
            for (;;) {
                if (hasQueuedPredecessors())
                    return -1;
                int available = getState();
                int remaining = available - acquires;
                if (remaining < 0 ||
                    compareAndSetState(available, remaining))
                    return remaining;
            }
        }
    }

为了方便了解主要逻辑,Sync类省略掉一些次要的方法。非公平版本号NonfairSync类和公平版本号FairSync类都继承于Sync类,Sync类继承于AQS类,NonfairSync和FairSync类都有相同的tryReleaseShared实现,仅仅只是在tryAcquireShared实现上有略微不同。

先来看看非公平类NonfairSync实现。tryAcquireShared调用的是Sync类的nonfairTryAcquireShared方法,方法的实现相当简单,仅仅是在循环内推断当前锁状态值减去请求值acquires后,假设remaining < 0(则表示此次acquire失败,直接返回负值remaining就可以)或者remaining >=0 时,compareAndSetState成功(表示此次acquire成功,直接返回大于等于0的remaining就可以),假设CAS失败,则继续循环重试,直到当中一种情况发生。

再来看看公平类FairSync的实现。tryAcquireShared直接被重写,与非公平类版本号对照,添加了hasQueuedPredecessors的推断,该方法在AQS中表示是否有结点在当前的等待队列前排在自己前面,假设返回true,则表示当前线程须要进入等待队列,直接返回-1表示acquire失败。

tryReleaseShared的实现也非常easy,也是一个循环里不断CAS把锁状态添加请求的releases就可以。

Semaphore还有其他一些辅助方法,事实上现也都是简单地调用内部类Sync的方法,这里便不再赘述。

总结

整体来看,AQS的锁状态值就等于Semaphore的许可量,acquire的实现就是把当前锁状态值,也就是许可量减去相应值,release的实现就是把锁状态值添加相应值就可以。整个实现结构和ReentrantLock类似,但没有了重入的逻辑,并且实现更是相对简单,理解起来应该没有难度。

时间: 2024-10-14 10:30:00

Semaphore实现Andoird版源代码剖析的相关文章

Semaphore实现Andoird版源码剖析

Semaphore是一个计数的信号量.从概念上来说,信号量维持一组许可(permits).acquire方法在必须的时候都会阻塞直到有一个许可可用,然后就会拿走这个许可.release方法添加一个许可,会有可能释放一个阻塞中的获取者(acquirer).然而,Semaphore没有使用真实的许可对象,只是保持一个可用计数并且采取相应的行为. 信号量一般用于限制可以访问一些(物理上或者逻辑上)的资源的并发线程数. 信号量初始化为1的时候,意味着它最多只有一个允许可用,这样就能作为互斥独占锁使用.这

STL源代码剖析——基本算法stl_algobase.h

前言 在STL中.算法是常常被使用的,算法在整个STL中起到很关键的数据.本节介绍的是一些基本算法,包括equal.fill.fill_n,iter_swap.lexicographical_compare.max,min.mismatch,swap,copy,copy_backward.copy_n.当中一个比較重要的算法就是copy.针对copy的剖析在源代码中能够看到具体的注解. 本文剖析的源代码出自SGL STL中的<stl_algobase.h>文件. 基本算法剖析 #ifndef

【Redis源代码剖析】 - Redis内置数据结构之压缩字典zipmap

原创作品,转载请标明:http://blog.csdn.net/Xiejingfa/article/details/51111230 今天为大家带来Redis中zipmap数据结构的分析,该结构定义在zipmap.h和zipmap.c文件里.我把zipmap称作"压缩字典"(不知道这样称呼正不对)是因为zipmap利用字符串实现了一个简单的hash_table结构,又通过固定的字节表示节省空间. zipmap和前面介绍的ziplist结构十分相似,我们能够对照地进行学习: Redis中

菜鸟nginx源代码剖析数据结构篇(六) 哈希表 ngx_hash_t(上)

Author:Echo Chen(陈斌) Email:[email protected] Blog:Blog.csdn.net/chen19870707 Date:October 31h, 2014 1.哈希表ngx_hash_t的优势和特点 哈希表是一种典型的以空间换取时间的数据结构.在没有冲突的情况下,对随意元素的插入.索引.删除的时间复杂度都是O(1).这样优秀的时间复杂度是通过将元素的key值以hash方法f映射到哈希表中的某一个位置来訪问记录来实现的,即键值为key的元素必然存储在哈希

菜鸟nginx源代码剖析数据结构篇(八) 缓冲区链表ngx_chain_t

菜鸟nginx源代码剖析数据结构篇(八) 缓冲区链表 ngx_chain_t Author:Echo Chen(陈斌) Email:[email protected]mail.com Blog:Blog.csdn.net/chen19870707 Date:Nov 6th, 2014 1.缓冲区链表结构ngx_chain_t和ngx_buf_t nginx的缓冲区链表例如以下图所看到的.ngx_chain_t为链表.ngx_buf_t为缓冲区结点: 2.源码位置 头文件:http://trac.

Qt中事件分发源代码剖析(一共8个步骤,顺序非常清楚:全局的事件过滤器,再传递给目标对象的事件过滤器,最终传递给目标对象)

Qt中事件分发源代码剖析 Qt中事件传递顺序: 在一个应该程序中,会进入一个事件循环,接受系统产生的事件,并且进行分发,这些都是在exec中进行的.下面举例说明: 1)首先看看下面一段示例代码: [cpp] view plaincopy int main(int argc, char *argv[]) { QApplication a(argc, argv); MouseEvent w; w.show(); return a.exec(); } 2)a.exec进入事件循环,调用的是QAppli

Android多线程研究(1)——线程基础及源代码剖析

从今天起我们来看一下Android中的多线程的知识,Android入门easy,可是要完毕一个完好的产品却不easy,让我们从线程開始一步步深入Android内部. 一.线程基础回想 package com.maso.test; public class TraditionalThread { public static void main(String[] args) { /* * 线程的第一种创建方式 */ Thread thread1 = new Thread(){ @Override p

《STL源代码剖析》---stl_deque.h阅读笔记(2)

看完,<STL源代码剖析>---stl_deque.h阅读笔记(1)后.再看代码: G++ 2.91.57,cygnus\cygwin-b20\include\g++\stl_deque.h 完整列表 /* * * Copyright (c) 1994 * Hewlett-Packard Company * * Permission to use, copy, modify, distribute and sell this software * and its documentation f

【Java集合源代码剖析】LinkedHashmap源代码剖析

转载请注明出处:http://blog.csdn.net/ns_code/article/details/37867985 前言:有网友建议分析下LinkedHashMap的源代码.于是花了一晚上时间研究了下,分享出此文(这个系列的最后一篇博文了),希望大家相互学习.LinkedHashMap的源代码理解起来也不难(当然.要建立在对HashMap源代码有较好理解的基础上). LinkedHashMap简单介绍 LinkedHashMap是HashMap的子类,与HashMap有着相同的存储结构.