首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 软件管理 > 软件架构设计 >

java并发库 Lock 公道锁和非公平锁

2012-08-31 
java并发库 Lock 公平锁和非公平锁????????? jdk1.5并发包中ReentrantLock的创建可以指定构造函数的boolea

java并发库 Lock 公平锁和非公平锁

????????? jdk1.5并发包中ReentrantLock的创建可以指定构造函数的boolean类型来得到公平锁或非公平锁,关于两者区别,java并发编程实践里面有解释

公平锁:?? Threads acquire a fair lock in the order in which they requested it
非公平锁:a nonfair lock permits barging: threads requesting a lock can jump ahead of the queue
of waiting threads if the lock happens to be available when it is requested.

公平锁,就是很公平,在并发环境中,每个线程在获取锁时会先查看此锁维护的等待队列,如果为空,或者当前线程线程是等待队列的第一个,就占有锁,否则就会加入到等待队列中,以后会按照FIFO的规则从队列中取到自己

非公平锁比较粗鲁,上来就直接尝试占有锁,如果尝试失败,就再采用类似公平锁那种方式

?

//公平获取锁? java.util.concurrent.locks.ReentrantLock$FairSync.java

protected final boolean tryAcquire(int acquires) {????final Thread current = Thread.currentThread();????int c = getState();????//状态为0,说明当前没有线程占有锁????if (c == 0) {????????//如果当前线程是等待队列的第一个或者等待队列为空,则通过cas指令设置state为1,当前线程获得锁????????if (isFirst(current) &&????????????compareAndSetState(0, acquires)) {????????????setExclusiveOwnerThread(current);????????????return true;????????}????}//如果当前线程本身就持有锁,那么叠加状态值,持续获得锁????else if (current == getExclusiveOwnerThread()) {????????int nextc = c + acquires;????????if (nextc < 0)????????????throw new Error("Maximum lock count exceeded");????????setState(nextc);????????return true;?????}?????//以上条件都不满足,那么线程进入等待队列。?????return false;

}

??????? //非公平获取锁? java.util.concurrent.locks.ReentrantLock$UnFairSync.java

?final boolean nonfairTryAcquire(int acquires) {
??????????? final Thread current = Thread.currentThread();
??????????? int c = getState();
??????????? if (c == 0) {

??????????????? //如果当前没有线程占有锁,当前线程直接通过cas指令占有锁,管他等待队列,就算自己排在队尾也是这样
??????????????? if (compareAndSetState(0, acquires)) {
??????????????????? setExclusiveOwnerThread(current);
??????????????????? return true;
??????????????? }
??????????? }
??????????? else if (current == getExclusiveOwnerThread()) {
??????????????? int nextc = c + acquires;
??????????????? if (nextc < 0) // overflow
??????????????????? throw new Error("Maximum lock count exceeded");
??????????????? setState(nextc);
??????????????? return true;
??????????? }
??????????? return false;
??????? }

?

?

?

热点排行