什么是可中断锁?有什么用?怎么实现?
发布网友
发布时间：2024-10-24 17:55
共1个回答
热心网友
时间：2024-10-29 17:14
在Java中有两种锁，一种是内置锁synchronized，一种是显示锁Lock，其中Lock锁是可中断锁，而synchronized则为不可中断锁。
所谓的中断锁指的是锁在执行时可被中断，也就是在执行时可以接收interrupt的通知，从而中断锁执行。
PS：默认情况下Lock也是不可中断锁，但是可以通过特殊的“手段”，可以让其变为可中断锁，接下来我们一起来看。
为什么需要可中断锁？不可中断锁的问题是，当出现“异常”时，只能一直阻塞等待，别无其他办法，比如下面这个程序。下面的这个程序中有两个线程，其中线程1先获取到锁资源执行相应代码，而线程2在0.5s之后开始尝试获取锁资源，但线程1执行时忘记释放锁了，这就造成线程2一直阻塞等待的情况，实现代码如下：
importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassInterruptiblyExample{publicstaticvoidmain(String[]args){Locklock=newReentrantLock();//创建线程1Threadt1=newThread(newRunnable(){@Overridepublicvoidrun(){lock.lock();System.out.println("线程1：获取到锁.");//线程1未释放锁}});t1.start();//创建线程2Threadt2=newThread(newRunnable(){@Overridepublicvoidrun(){//先休眠0.5s，让线程1先执行try{Thread.sleep(500);}catch(InterruptedExceptione){e.printStackTrace();}//获取锁System.out.println("线程2:等待获取锁.");lock.lock();try{System.out.println("线程2：获取锁成功.");}finally{lock.unlock();}}});t2.start();}}以上代码执行的结果如下：
从上述结果可以看出，此时线程2在等待获取锁的操作，然而经历了N久之后...
再次查看结果，依然是熟悉的画面：
线程2还在阻塞等待获取线程1释放锁资源，此时的线程2除了等之外，并无其他方法。
并且，但我们熟练的拿出了JConsole，试图得到一个死锁的具体信息时，却得到了这样的结果：
并没有检测到任何死锁信息，从上图我们可以看出，当只有一个锁资源的时候，系统并不会把这种情况判定为死锁，当然也没有阻塞等待的具体信息喽，此时只剩下线程2孤单地等待着它的“锁儿”。
使用中断锁然而，中断锁的出现，就可以打破这一僵局，它可以在等待一定时间之后，主动的中断线程2，以解决线程阻塞等待的问题。
中断锁的核心实现代码是lock.lockInterruptibly()方法，它和lock.lock()方法作用类似，只不过使用lockInterruptibly方法可以优先接收中断的请求，中断锁的具体实现如下：
importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassInterruptiblyExample{publicstaticvoidmain(String[]args)throwsInterruptedException{Locklock=newReentrantLock();//创建线程1Threadt1=newThread(newRunnable(){@Overridepublicvoidrun(){try{//加锁操作lock.lock();System.out.println("线程1:获取到锁.");}catch(InterruptedExceptione){e.printStackTrace();}//线程1未释放锁}});t1.start();//创建线程2Threadt2=newThread(newRunnable(){@Overridepublicvoidrun(){//先休眠0.5s，让线程1先执行try{Thread.sleep(500);}catch(InterruptedExceptione){e.printStackTrace();}//获取锁try{System.out.println("线程2:尝试获取锁.");lock.lockInterruptibly();//可中断锁System.out.println("线程2:获取锁成功.");}catch(InterruptedExceptione){System.out.println("线程2:执行已被中断.");}}});t2.start();//等待2s后,终止线程2Thread.sleep(2000);if(t2.isAlive()){//线程2还在执行System.out.println("执行线程的中断.");t2.interrupt();}else{System.out.println("线程2:执行完成.");}}}以上代码执行结果如下：
从上述结果可以看出，当我们使用了lockInterruptibly方法就可以在一段时间之后，判断它是否还在阻塞等待，如果结果为真，就可以直接将他中断，如上图效果所示。
但当我们尝试将lockInterruptibly方法换成lock方法之后（其他代码都不变），执行的结果就完全不一样了，实现代码如下：
importjava.util.concurrent.locks.Lock;importjava.util.concurrent.locks.ReentrantLock;publicclassInterruptiblyExample{publicstaticvoidmain(String[]args)throwsInterruptedException{Locklock=newReentrantLock();//创建线程1Threadt1=newThread(newRunnable(){@Overridepublicvoidrun(){try{//加锁操作lock.lockInterruptibly();System.out.println("线程1:获取到锁.");}catch(InterruptedExceptione){e.printStackTrace();}//线程1未释放锁}});t1.start();//创建线程2Threadt2=newThread(newRunnable(){@Overridepublicvoidrun(){//先休眠0.5s，让线程1先执行try{Thread.sleep(500);}catch(InterruptedExceptione){e.printStackTrace();}//获取锁try{System.out.println("线程2:尝试获取锁.");lock.lock();System.out.println("线程2:获取锁成功.");}catch(Exceptione){System.out.println("线程2:执行已被中断.");}}});t2.start();//等待2s后,终止线程2Thread.sleep(2000);if(t2.isAlive()){//线程2还在执行System.out.println("执行线程的中断.");t2.interrupt();}else{System.out.println("线程2:执行完成.");}}}以上程序执行结果如下：
从上图可以看出，当使用lock方法时，即使调用了interrupt方法依然不能将线程2进行中断。
总结本文介绍了中断锁的实现，通过显示锁Lock的lockInterruptibly方法来完成，它和lock方法作用类似，但lockInterruptibly可以优先接收到中断的通知，而lock方法只能“死等”锁资源的释放，同时这两个方法的区别也是常见的面试题，希望本文对你有用。
关注公号「Java中文社群」查看更多有意思、涨知识的Java并发文章。
