一般的代码中,尤其是作为一个基础类库时,绝不应当吞掉中断,即捕获到InterruptedException后在catch里什么也不做,清除中断状态后又不重设中断状态也不抛出InterruptedException等。因为吞掉中断状态会导致方法调用栈的上层得不到这些信息。 当然,凡事总有例外的时候,当你完全清楚自己的方法会被谁调用,而调用者也不会因为中断被吞掉了而遇到麻烦,就可以这么做。 总得来说,就是要让方法调用栈的上层获知中断的发生。假设你写了一个类库,类库里有个方法amethod,在amethod中检测并清除了中断状态,而没有抛出InterruptedException,作为amethod的用户来说,他并不知道里面的细节,如果用户在调用amethod后也要使用中断来做些事情,那么在调用amethod之后他将永远也检测不到中断了,因为中断信息已经被amethod清除掉了。如果作为用户,遇到这样有问题的类库,又不能修改代码,那该怎么处理?只好在自己的类里设置一个自己的中断状态,在调用interrupt方法的时候,同时设置该状态,这实在是无路可走时才使用的方法。 2、 中断的响应 程序里发现中断后该怎么响应?这就得视实际情况而定了。有些程序可能一检测到中断就立马将线程终止,有些可能是退出当前执行的任务,继续执行下一个任务……作为一种协作机制,这要与中断方协商好,当调用interrupt会发生些什么都是事先知道的,如做一些事务回滚操作,一些清理工作,一些补偿操作等。若不确定调用某个线程的interrupt后该线程会做出什么样的响应,那就不应当中断该线程。 4. Thread.interrupt VS Thread.stop Thread.stop方法已经不推荐使用了。而在某些方面Thread.stop与中断机制有着相似之处。如当线程在等待内置锁或IO时,stop跟interrupt一样,不会中止这些操作;当catch住stop导致的异常时,程序也可以继续执行,虽然stop本意是要停止线程,这么做会让程序行为变得更加混乱。 那么它们的区别在哪里?最重要的就是中断需要程序自己去检测然后做相应的处理,而Thread.stop会直接在代码执行过程中抛出ThreadDeath错误,这是一个java.lang.Error的子类。 在继续之前,先来看个小例子: 01 package com.ticmy.interrupt; 02 import java.util.Arrays; 03 import java.util.Random; 04 import java.util.concurrent.TimeUnit; 05 public class TestStop { 06 private static final int[] array = new int[80000]; 07 private static final Thread t = new Thread() { 08 public void run() { 09 try { 10 System.out.println(sort(array)); 11 } catch (Error err) { 12 err.printStackTrace(); 13 } 14 System.out.println("in thread t"); 15 } 16 }; 17 18 static { 19 Random random = new Random(); 20 for(int i = 0; i < array.length; i++) { 21 array[i] = random.nextInt(i + 1); 22 } 23 } 24 25 private static int sort(int[] array) { 26 for (int i = 0; i < array.length-1; i++){ 27 for(int j = 0 ;j < array.length - i - 1; j++){ 28 if(array[j] < array[j + 1]){ 29 int temp = array[j]; 30 array[j] = array[j + 1]; 31 array[j + 1] = temp; 32 } 33 } 34 } 35 return array[0]; 36 } 37 38 public static void main(String[] args) throws Exception { 39 t.start(); 40 TimeUnit.SECONDS.sleep(1); 41 System.out.println("go to stop thread t"); 42 t.stop(); 43 System.out.println("finish main"); 44 } 45 } 这个例子很简单,线程t里面做了一个非常耗时的排序操作,排序方法中,只有简单的加、减、赋值、比较等操作,一个可能的执行结果如下: go to stop thread t java.lang.ThreadDeath at java.lang.Thread.stop(Thread.java:758) at com.ticmy.interrupt.TestStop.main(TestStop.java:44) finish main in thread t 这里sort方法是个非常耗时的操作,也就是说主线程休眠一秒钟后调用stop的时候,线程t还在执行sort方法。就是这样一个简单的方法,也会抛出错误!换一句话说,调用stop后,大部分Java字节码都有可能抛出错误,哪怕是简单的加法! 如果线程当前正持有锁,stop之后则会释放该锁。由于此错误可能出现在很多地方,那么这就让编程人员防不胜防,极易造成对象状态的不一致。例如,对象obj中存放着一个范围值:最小值low,最大值high,且low不得大于high,这种关系由锁lock保护,以避免并发时产生竞态条件而导致该关系失效。假设当前low值是5,high值是10,当线程t获取lock后,将low值更新为了15,此时被stop了,真是糟糕,如果没有捕获住stop导致的Error,low的值就为15,high还是10,这导致它们之间的小于关系得不到保证,也就是对象状态被破坏了!如果在给low赋值的时候catch住stop导致的Error则可能使后面high变量的赋值继续,但是谁也不知道Error会在哪条语句抛出,如果对象状态之间的关系更复杂呢?这种方式几乎是无法维护的,太复杂了!如果是中断操作,它决计不会在执行low赋值的时候抛出错误,这样程序对于对象状态一致性就是可控的。 正是因为可能导致对象状态不一致,stop才被禁用。 5. 中断的使用 通常,中断的使用场景有以下几个:
下面来看一个具体的例子。这个例子里,本打算采用GUI形式,但考虑到GUI代码会使程序复杂化,就使用控制台来模拟下核心的逻辑。这里新建了一个磁盘文件扫描的任务,扫描某个目录下的所有文件并将文件路径打印到控制台,扫描的过程可能会很长。若需要中止该任务,只需在控制台键入quit并回车即可。 01 package com.ticmy.interrupt; 02 import java.io.BufferedReader; 03 import java.io.File; 04 import java.io.InputStreamReader; 05 06 public class FileScanner { 07 private static void listFile(File f) throws InterruptedException { 08 if(f == null) { 09 throw new IllegalArgumentException(); 10 } 11 if(f.isFile()) { 12 System.out.println(f); 13 return; 14 } 15 File[] allFiles = f.listFiles(); 16 if(Thread.interrupted()) { 17 throw new InterruptedException("文件扫描任务被中断"); 18 } 19 for(File file : allFiles) { 20 //还可以将中断检测放到这里 21 listFile(file); 22 } 23 } 24 25 public static String readFromConsole() { 26 BufferedReader reader = new BufferedReader(newInputStreamReader(System.in)); 27 try { 28 return reader.readLine(); 29 } catch (Exception e) { 30 e.printStackTrace(); 31 return ""; 32 } 33 } 34 35 public static void main(String[] args) throws Exception { 36 final Thread fileIteratorThread = new Thread() { 37 public void run() { 38 try { 39 listFile(new File("c:\\")); 40 } catch (InterruptedException e) { 41 e.printStackTrace(); 42 } 43 } 44 }; 45 new Thread() { 46 public void run() { 47 while(true) { 48 if("quit".equalsIgnoreCase(readFromConsole())) { 49 if(fileIteratorThread.isAlive()) { 50 fileIteratorThread.interrupt(); 51 return; 52 } 53 } else { 54 System.out.println("输入quit退出文件扫描"); 55 } 56 } 57 } 58 }.start(); 59 fileIteratorThread.start(); 60 } 61 } 在扫描文件的过程中,对于中断的检测这里采用的策略是,如果碰到的是文件就不检测中断,是目录才检测中断,因为文件可能是非常多的,每次遇到文件都检测一次会降低程序执行效率。此外,在fileIteratorThread线程中,仅是捕获了InterruptedException,没有重设中断状态也没有继续抛出异常,因为我非常清楚它的使用环境,run方法的调用栈上层已经没有可能需要检测中断状态的方法了。 在这个程序中,输入quit完全可以执行System.exit(0)操作来退出程序,但正如前面提到的,这是个GUI程序核心逻辑的模拟,在GUI中,执行System.exit(0)会使得整个程序退出。