使用中断锁
然而，中断锁的出现，就可以打破这一僵局，它可以在等待一定时间之后，主动的中断线程 2，以解决线程阻塞等待的问题。
中断锁的核心实现代码是 lock.lockInterruptibly() 方法，它和 lock.lock() 方法作用类似，只不过使用 lockInterruptibly 方法可以优先接收中断的请求，中断锁的具体实现如下：
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; publicclass InterruptiblyExample { public static void main(String[] args) throws InterruptedException { Lock lock = new ReentrantLock(); // 创建线程 1 Thread t1 = new Thread(new Runnable() { @Override public void run() { try { // 加锁操作 lock.lock(); System.out.println("线程 1:获取到锁."); } catch (InterruptedException e) { e.printStackTrace(); } // 线程 1 未释放锁 } }); t1.start(); // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { // 先休眠 0.5s，让线程 1 先执行 try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } // 获取锁 try { System.out.println("线程 2:尝试获取锁."); lock.lockInterruptibly(); // 可中断锁 System.out.println("线程 2:获取锁成功."); } catch (InterruptedException e) { System.out.println("线程 2:执行已被中断."); } } }); t2.start(); // 等待 2s 后,终止线程 2 Thread.sleep(2000); if (t2.isAlive()) { // 线程 2 还在执行 System.out.println("执行线程的中断."); t2.interrupt(); } else { System.out.println("线程 2:执行完成."); } } }
以上代码执行结果如下：
从上述结果可以看出，当我们使用了 lockInterruptibly 方法就可以在一段时间之后，判断它是否还在阻塞等待，如果结果为真，就可以直接将他中断，如上图效果所示。
