当前位置 : 主页 > 编程语言 > c++ >

带默认自旋次数的自适应独占锁,能够动态的根据线程获取锁的等待次数来决定

来源:互联网 收集:自由互联 发布时间:2021-06-30
AdaptionLock.java import java.util.concurrent.locks.ReentrantLock;/** * 带默认自旋次数的自适应独占锁,能够动态的根据线程获取锁的等待次数来决定是使用tryLock还是lock来获取锁 * * 1.tryLock-内部使用
AdaptionLock.java
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();
	}
}
网友评论