最近打算读一下《实战java高并发程序设计》，夯实一下java多线程的知识。接下来应该会写一系列的读书笔记,里面会有多处引用到书中的代码或者文字。本文就是第一篇。
不推荐使用的stop方法
Thread.stop()是一个被废弃的方法,不被推荐使用的原因是stop方法太过于暴力，强行把执行到一半的线程终止,并且会立即释放这个线程所有的锁。会破坏了线程中引用对象的一致性。
例如在数据库中维护着一张用户表，记录了用户ID和用户名，使用Thread多线程写入两条记录:
记录1: ID=1,NAME=小明
记录2: ID=2,NAME=小王
如果在记录1写到一半的时候被stop结束了，就可能出现各种奇怪的现象：
- 记录1被记录2覆盖，没有任何数据留下。
- 记录1只有一半，即只有ID，而NAME为空。
- 记录1和记录2混在同一条记录中，最后写入了一条一半是记录1一半是记录2的脏数据
所以,除非你很确定你在做什么,否则不要轻易使用stop方法
使用判断标志位的方法中断线程
那如果的确有中断线程的需求,我们需要怎么做呢？一般我们马上就会想到设置标志位的方法,即在线程中执行每一个步骤之前都判断一下是否需要退出线程:
class WorkThread extends Thread {
private boolean mExitThread = false;
public void exitThread() {
mExitThread = true;
}
@Override
public void run() {
if (mExitThread) {
return;
}
//do something
if (mExitThread) {
return;
}
//do something
if (mExitThread) {
return;
}
//do something
}
}
其实Thread类早就帮我们实现了这个中断标志了。与Thread中断相关的方法有下面三个:
public void Thread.interrupt() //线程中断
public native boolean Thread.isInterrupted() //判断是否被中断
public static native boolean Thread.interrupted() //判断是否中断,并清除当前中断状态
所以上面的代码可以改写成这样:
class WorkThread extends Thread {
@Override
public void run() {
if (isInterrupted()) {
return;
}
//do something
if (isInterrupted()) {
return;
}
//do something
if (isInterrupted()) {
return;
}
//do something
}
}
这个时候我们只需要调用Thread.interrupt()方法就能安全的中断线程了。
需要提醒一下的是Thread.interrupt()方法并不会像Thread.stop()方法一样立即结束线程,它只是设置了一个中断标志,需要在代码实现中去手动判断这个标志并且推出。
像下面这个代码就算掉了Thread.interrupt()方法也不会中断线程:
class WorkThread extends Thread {
@Override
public void run() {
while(true){
//do something
}
}
}
Thread.interrupt的优点
使用Thread.interrupt去中断线程除了可以免去自己实现标志位的烦恼之外,还可以中断sleep和wait中的线程。
还记得我们在调用Thread.sleep()这个方法的时候都需要catch或者抛出InterruptedException这个异常吗:
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
这个InterruptedException异常就是由于我们调用了Thread.interrupt方法抛出的。所以Thread.interrupt可以打断Thread.sleep。同样Thread.wait也是可以被Thread.interrupt打断的。
需要注意的是如果sleep方法由于中断而抛出异常，此时，它会清除中断标记。所以在catch到这个异常的时候需要再次设置中断标记：
Thread t1 = new Thread() {
@Override
public void run(){
while(true){
if(Thread.currentThread().isInterrupted()){
break;
}
System.out.println("hello world");
try{
Thread.sleep(1000);
}catch(InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
};
