##简介
Java提供了2个关于线程挂起和恢复的接口,一个是suspend用于挂起线程,一个是resume接口用于唤醒线程。这2个线程都是被废弃的接口,因为他们和stop一样是不安全的。 suspend挂起线程不会释放线程当前占用的资源,并且resume比suspend提前调用的话就会造成线程一直挂起,并且从堆栈中不容易分析,因为suspend挂起的线程是状态是Runnable,这就意味着常规的分析方法和工具很难定位到问题。只有对多次堆栈的dump进行全部分析才有机会定位到问题。 下面展示一个因为先执行了resume而导致挂死的例子。
不优雅的suspend
import java.util.concurrent.TimeUnit;public class SuspendTest { static Object lock = new Object(); @SuppressWarnings("deprecation") public static void main(String[] args) { Suspend s1 = new Suspend(); Suspend s2 = new Suspend(); s1.start(); try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } s1.resume(); s2.start(); s2.resume(); } static class Suspend extends Thread{ @SuppressWarnings("deprecation") @Override public void run() { synchronized(lock){ try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } Thread.currentThread().suspend(); } } }}
上面的例子的一般情况s1是可以执行完成的,是因为先执行了suspend,后执行resume,而s2就被挂死了,因为s2先执行了resume,后执行的suspend。
下面是挂死之后上的堆栈信息:
"Thread-1" prio=6 tid=0x000000000c7bf000 nid=0x15a4 runnable [0x000000000d21e000] java.lang.Thread.State: RUNNABLE at java.lang.Thread.suspend0(Native Method) at java.lang.Thread.suspend(Unknown Source) at cn.d.concurrent.SuspendTest$Suspend.run(SuspendTest.java:34) - locked <0x00000007d5e99f78> (a java.lang.Object)
从上面的堆栈信息分析可以知道被挂死的s2的线程状态是RUNNABLE,并且没有释放它锁占用的锁0x00000007d5e99f78。
上面被挂死的原因有一部分是刻意为之,但是在多线程调度不确定的情况下不刻意,使用suspend也很容易找出挂死,因为它的确有一些问题,所以才会被废弃。
suspend的代替方法
需要用到suspend的地方基本都刻意替换为wait,notify模式,如果你想要简单实现,刻意考虑JUC提供的工具LockSupport。下面的例子使用LockSupport工具替换上面例子的suspend和resume方法。
import java.util.concurrent.TimeUnit;import java.util.concurrent.locks.LockSupport;public class SuspendTest2 { static Object lock = new Object(); public static void main(String[] args) { Suspend s1 = new Suspend(); Suspend s2 = new Suspend(); s1.start(); try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } LockSupport.unpark(s1); s2.start(); LockSupport.unpark(s2); } static class Suspend extends Thread{ @Override public void run() { synchronized(lock){ try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } LockSupport.park(); } } }}
使用LockSupport工具的静态方法轻松加愉快的就解决了suspend和resume带来的问题。
总结
- 尽量不要使用suspend来挂起线程
- 考虑使用wait,notify模式来代替suspend
- 考虑使用JUC的LockSupport来代替suspend