您好,登錄后才能下訂單哦!
小編這次要給大家分享的是什么是JAVA Lock鎖,文章內(nèi)容豐富,感興趣的小伙伴可以來了解一下,希望大家閱讀完這篇文章之后能夠有所收獲。
同樣是鎖,先說說synchronized和lock的區(qū)別:
寫個(gè)Demo
static Lock lock = new ReentrantLock();public static void main(String[] args) throws InterruptedException { lock.lock();//其他沒拿到鎖的卡住不動(dòng) Thread thread = new Thread(new Runnable() { @Override public void run() { System.out.println("start to get lock Interruptibly"); lock.unlock(); //看看會(huì)發(fā)生什么,注釋掉再看看 lock.lock(); System.out.println("拿到鎖"); lock.unlock(); System.out.println("釋放鎖"); } }); thread.start(); Thread.sleep(3000); lock.unlock(); }
我們自己來手寫一下lock接口的tryLock()、lock()和unLock()方法,實(shí)現(xiàn)我們自己的myLock。
public class MyLock implements Lock { //多并發(fā)調(diào)用 0-未占用 大于0-占用 AtomicInteger state = new AtomicInteger(); Thread ownerThread = new Thread(); //等待鎖的隊(duì)列 LinkedBlockingQueue<Thread> waiters = new LinkedBlockingQueue(); @Override public void lock() { if (!tryLock()) { //先搶鎖,所以是非公平鎖 //沒拿到鎖,放到隊(duì)列中去進(jìn)行排隊(duì) waiters.add(Thread.currentThread()); //等待被喚醒 for (; ; ) { if (tryLock()) { //非公平鎖情況下,喚醒過來繼續(xù)獲取鎖 waiters.poll(); //獲取鎖成功把自己從隊(duì)列中取出來 return; } else //獲取鎖失敗 LockSupport.park(); //線程阻塞 } } } @Override public boolean tryLock() { if (state.get() == 0) { //如果鎖沒被占用 if (state.compareAndSet(0, 1)) { //如果成功拿到鎖 ownerThread = Thread.currentThread(); //占用鎖線程改為當(dāng)前線程 return true; } } return false; } @Override public void unlock() { if (ownerThread != Thread.currentThread()) //占用鎖線程不是當(dāng)前線程無法釋放鎖 throw new RuntimeException("非法調(diào)用,當(dāng)前鎖不屬于你"); if (state.decrementAndGet() == 0) //如果成功釋放鎖 ownerThread = null; //占用鎖線程置空 //通知其他線程 // Thread thread = null; // // while ((thread = waiters.peek()) != null) // LockSupport.unpark(thread); Thread thread = waiters.peek(); //獲取隊(duì)列頭部線程,線程還留在隊(duì)列中 if (thread != null) { LockSupport.unpark(thread); //取消阻塞 } } @Override public boolean tryLock(long time, TimeUnit unit) throws InterruptedException { return false; } @Override public Condition newCondition() { return null; } @Override public void lockInterruptibly() throws InterruptedException { } }
幾個(gè)注意點(diǎn):
Lock默認(rèn)是非公平鎖,上面實(shí)現(xiàn)的也是非公平鎖,小伙伴們可以試一試。
公平鎖和非公平鎖區(qū)別:
先等待先獲取鎖是公平鎖;先等待也不一定先獲取鎖,可能被突然到來的線程獲取到是非公平鎖;
公平鎖的實(shí)現(xiàn):
@Override public void lock() { checkQueue();//線程來的時(shí)候先不獲取鎖,而是先檢查隊(duì)列中有沒有等待的線程,如果有,直接放入隊(duì)列,如果沒有,再去獲取鎖 if (!tryLock()) { //先搶鎖,所以是非公平鎖 //沒拿到鎖,放到隊(duì)列中去進(jìn)行排隊(duì) waiters.add(Thread.currentThread()); //等待被喚醒 for (; ; ) { if (tryLock()) { //非公平鎖情況下,喚醒過來繼續(xù)獲取鎖 waiters.poll(); //獲取鎖成功把自己從隊(duì)列中取出來 return; } else //獲取鎖失敗 LockSupport.park(); //線程阻塞 } } }
看完這篇關(guān)于什么是JAVA Lock鎖的文章,如果覺得文章內(nèi)容寫得不錯(cuò)的話,可以把它分享出去給更多人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。