AdaptionLock.java import java.util.concurrent.locks.ReentrantLock;/** * 带默认自旋次数的自适应独占锁,能够动态的根据线程获取锁的等待次数来决定是使用tryLock还是lock来获取锁 * * 1.tryLock-内部使用
import java.util.concurrent.locks.ReentrantLock;
/**
* 带默认自旋次数的自适应独占锁,能够动态的根据线程获取锁的等待次数来决定是使用tryLock还是lock来获取锁
*
* 1.tryLock->内部使用的是CAS操作获取锁,是一次简单的判定。
* 在ReentrantLock源码中,其本身的lock()操作也会调用一次tryLock()来尝试获取锁,
* 获取失败则将线程加入CLH等待队列,然后通过acquireQueued()来获取锁
*
* 2.lock->内部会先通过一次tryLock()来尝试获取锁,若获取失败则将需获取锁的线程加入CLH等待队列,然后通过acquireQueued()获取锁
* 而acquireQueued()的作用就是逐步的去执行CLH队列的线程,如果当前线程获取到了锁,则返回;
* 否则,当前线程进行休眠,直到唤醒并重新获取锁了才返回。
*
* @author 夏天的冬天 2017年5月12日
*
*/
@SuppressWarnings("serial")
public class AdaptionLock extends ReentrantLock {
private int adapt = 20;// 默认自旋次数
public AdaptionLock() {
super();
}
public AdaptionLock(boolean fair) {
super(fair);
}
public int getAdapt() {
return adapt;
}
public void setAdapt(int adapt) {
this.adapt = adapt;
}
@Override
public void lock() {
// 该锁的自旋次数还有,即还可进行自旋优化
if (adapt > 0) {
for (int i = 1; i <= adapt; i++) {
// 在给定的自旋次数内,完成了对锁的获取
if (this.tryLock()) {
/**
* 在指定的范围内可以完成,表示自旋取得锁的可能性较大,该线程等待的时间较短。
* 并且自旋超出给定的一半限定,则扩大限定。 这里对adapt的操作无需保证同步。
*/
// System.out.println("自旋" + i + "次,取得了锁::当前自旋次数为:" + adapt);
if (i > adapt / 2)
adapt *= 2;
return;
}
}
/**
* 到了这里,表明在指定的次数内,没有获取锁,则可以认为下一次也不会通过自旋取得锁,该线程等待的时间较长。
* 则将自旋次数减少一半,直到直接使用lock取得锁,不再进行无用的自旋操作。 这里对adapt的操作无需保证同步。
*/
adapt /= 2;
}
// System.out.println("自旋未取得锁" + "::当前自旋次数为:" + adapt);
super.lock();
}
}
