线程中断 interrupt 和 LockSupport (2)

park方法对中断方法的响应和 sleep 有一些不太一样。它不会抛出中断异常,而是从park方法直接返回,不影响线程的继续执行。我们看下代码:

public class LockSupportTest { public static void main(String[] args) throws InterruptedException { Thread t = new Thread(new ParkThread()); t.start(); Thread.sleep(100); //① System.out.println(Thread.currentThread().getName()+"开始唤醒阻塞线程"); t.interrupt(); System.out.println(Thread.currentThread().getName()+"结束唤醒"); } } class ParkThread implements Runnable{ @Override public void run() { System.out.println(Thread.currentThread().getName()+"开始阻塞"); LockSupport.park(); System.out.println(Thread.currentThread().getName()+"第一次结束阻塞"); LockSupport.park(); System.out.println("第二次结束阻塞"); } }

打印结果如下:

Thread-0开始阻塞 main开始唤醒阻塞线程 main结束唤醒 Thread-0第一次结束阻塞 第二次结束阻塞

当调用interrupt方法时,会把中断状态设置为true,然后park方法会去判断中断状态,如果为true,就直接返回,然后往下继续执行,并不会抛出异常。注意,这里并不会清除中断标志。

unpark

unpark会唤醒被park的指定线程。但是,这里要说明的是,unpark 并不是简单的直接去唤醒被park的线程。看下JDK的解释:

线程中断 interrupt 和 LockSupport

unpark只是给当前线程设置一个许可证。如果当前线程已经被阻塞了(即调用了park),则会转为不阻塞的状态。如若不然,下次调用park方法的时候也会保证不阻塞。这句话的意思,其实是指,park和unpark的调用顺序无所谓,只要unpark设置了这个许可证,park方法就可以在任意时刻消费许可证,从而不会阻塞方法。

还需要注意的是,许可证最多只有一个,也就是说,就算unpark方法调用多次,也不会增加许可证。 我们可以通过代码验证,只需要把上边代码修改一行即可:

//LockSupportTest类 //原代码 t.interrupt(); //修改为 LockSupport.unpark(t); LockSupport.unpark(t);

就会发现,只有第一次阻塞会被唤醒,但是第二次依然会继续阻塞。结果如下:

Thread-0开始阻塞 main开始唤醒阻塞线程 main结束唤醒 Thread-0第一次结束阻塞

另外,在此基础上,把主线程的sleep方法去掉(代码中①处),让主线程先运行,也就是有可能先调用unpark方法,然后子线程才开始调用park方法阻塞。我们会发现,出现以下结果,证明了上边我说的park方法和unpark不分先后顺序,park方法可以随时消费许可证。

main开始唤醒阻塞线程 main结束唤醒 Thread-0开始阻塞 Thread-0第一次结束阻塞 park/unpark和 wait/notify区别

了解了 park/unpark的用法之后,想必你也能分析出来它们和 wait、notify有什么不同之处了。

1) wait和notify方法必须和同步锁 synchronized一块儿使用。而park/unpark使用就比较灵活了,没有这个限制,可以在任何地方使用。

2) park/unpark 使用时没有先后顺序,都可以使线程不阻塞(前面代码已验证)。而wait必须在notify前先使用,如果先notify,再wait,则线程会一直等待。

3) notify只能随机释放一个线程,并不能指定某个特定线程,notifyAll是释放锁对象中的所有线程。而unpark方法可以唤醒指定的线程。

4) 调用wait方法会使当前线程释放锁资源,但使用的前提是必须已经获得了锁。 而park不会释放锁资源。(以下代码验证)

public class LockSyncTest { private static Object lock = new Object(); //保存调用park的线程,以便后续唤醒 private static Thread parkedThread; public static void main(String[] args) throws InterruptedException { Thread t1 = new Thread(()->{ synchronized (lock){ System.out.println("unpark前"); LockSupport.unpark(parkedThread); System.out.println("unpark后"); } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { //和t1线程用同一把锁时,park不会释放锁资源,若换成this锁,则会释放锁 synchronized (lock){ System.out.println("park前"); parkedThread = Thread.currentThread(); LockSupport.park(); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("park后"); } } }); t2.start(); Thread.sleep(100); t1.start(); } } //打印结果 //park前

以上代码,会一直卡在t2线程,因为park不会释放锁,因此t1也无法执行。

如果把t2的锁换成this锁,即只要和t1不是同一把锁,则t1就会正常执行,然后把t2线程唤醒。打印结果如下:

park前 unpark前 unpark后 park后

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wsxgys.html