记录一下公平锁,非公平锁,可重入锁(递归锁),读写锁,自旋锁的概念,以及一些和锁有关的java类。
公平锁与非公平锁:
公平锁就是在多线程环境下,每个线程在获取锁时,先查看这个锁维护的队列,如果队列为空或者自身就是等待队列的第一个,就占有锁。否则就加入到等待队列中,按照FIFO的顺序依次占有锁。
非公平锁会一上来就试图占有锁,如果占有失败,再按照公平锁的方式等待。
公平锁和非公平锁可以用 Lock lock = new ReentrantLock(boolean fair)的方式创建(默认为非公平锁,相当于fair为false)。Synchronized是一种非公平锁。非公平锁的优点在于吞吐量比公平锁大
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 ; } //非公平占有锁 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; }
可重入锁:
可重入锁又叫递归锁,其实就是ReentrantLock。reentrant 译为可重入,意味着线程可以进入它已经拥有的锁的同步代码块。
它有一个与锁相关的获取计数器,如果拥有锁的某个线程再次得到锁,那么获取计数器就加1,然后锁需要被释放两次才能获得真正释放。这模仿了 synchronized
的语义;如果线程进入由线程已经拥有的监控器保护的 synchronized 块,就允许线程继续进行,当线程退出第二个(或者后续) synchronized
块的时候,不释放锁,只有线程退出它进入的监控器保护的第一个 synchronized
块时,才释放锁。
下面引用一个可重入锁和不可重入的设计(https://blog.csdn.net/u012545728/article/details/80843595)
//可重入锁的设计 public class MyReentrantLock{ boolean isLocked = false; Thread lockedBy = null; int lockedCount = 0; public synchronized void lock() throws InterruptedException{ Thread thread = Thread.currentThread(); while(isLocked && lockedBy != thread){ wait(); } isLocked = true; lockedCount++; lockedBy = thread; } public synchronized void unlock(){ if(Thread.currentThread() == this.lockedBy){ lockedCount--; if(lockedCount == 0){ isLocked = false; notify(); } } } } //不可重入锁的设计 public class UnReentrantLock{ private boolean isLocked = false; public synchronized void lock() throws InterruptedException{ while(isLocked){ wait(); } isLocked = true; } public synchronized void unlock(){ isLocked = false; notify(); } }
未完待续。。。
原文:https://www.cnblogs.com/dream2true/p/10781071.html