这样的情景您也许并不陌生:您在编写一个测试程序,程序需要暂停一段时间,于是调用 Thread.sleep()
。但是编译器或 IDE 报错说没有处理检查到的 InterruptedException
。InterruptedException
是什么呢,为什么必须处理它?
对于 InterruptedException
,一种常见的处理方式是 “生吞(swallow)” 它 —— 捕捉它,然后什么也不做(或者记录下它,不过这也好不到哪去)—— 就像后面的 清单 4 一样。不幸的是,这种方法忽略了这样一个事实:这期间可能发生中断,而中断可能导致应用程序丧失及时取消活动或关闭的能力。
当一个方法抛出 InterruptedException
时,它不仅告诉您它可以抛出一个特定的检查异常,而且还告诉您其他一些事情。例如,它告诉您它是一个阻塞(blocking)方法,如果您响应得当的话,它将尝试消除阻塞并尽早返回。
阻塞方法不同于一般的要运行较长时间的方法。一般方法的完成只取决于它所要做的事情,以及是否有足够多可用的计算资源(CPU 周期和内存)。而阻塞方法的完成还取决于一些外部的事件,例如计时器到期,I/O 完成,或者另一个线程的动作(释放一个锁,设置一个标志,或者将一个任务放在一个工作队列中)。一般方法在它们的工作做完后即可结束,而阻塞方法较难于预 测,因为它们取决于外部事件。阻塞方法可能影响响应能力,因为难于预测它们何时会结束。
阻塞方法可能因为等不到所等的事件而无法终止,因此令阻塞方法可取消 就非常有用(如果长时间运行的非阻塞方法是可取消的,那么通常也非常有用)。可取消操作是指能从外部使之在正常完成之前终止的操作。由 Thread
提供并受 Thread.sleep()
和 Object.wait()
支持的中断机制就是一种取消机制;它允许一个线程请求另一个线程停止它正在做的事情。当一个方法抛出 InterruptedException
时,它是在告诉您,如果执行该方法的线程被中断,它将尝试停止它正在做的事情而提前返回,并通过抛出 InterruptedException
表明它提前返回。 行为良好的阻塞库方法应该能对中断作出响应并抛出 InterruptedException
,以便能够用于可取消活动中,而不至于影响响应。
每个线程都有一个与之相关联的 Boolean 属性,用于表示线程的中断状态(interrupted status)。中断状态初始时为 false;当另一个线程通过调用 Thread.interrupt()
中断一个线程时,会出现以下两种情况之一。如果那个线程在执行一个低级可中断阻塞方法,例如 Thread.sleep()
、 Thread.join()
或 Object.wait()
,那么它将取消阻塞并抛出 InterruptedException
。否则, interrupt()
只是设置线程的中断状态。 在被中断线程中运行的代码以后可以轮询中断状态,看看它是否被请求停止正在做的事情。中断状态可以通过 Thread.isInterrupted()
来读取,并且可以通过一个名为 Thread.interrupted()
的操作读取和清除。
中断是一种协作机制。当一个线程中断另一个线程时,被中断的线程不一定要立即停止正在做的事情。相反,中断是礼貌地请求另一个线程在它愿意并且方便的时候停止它正在做的事情。有些方法,例如 Thread.sleep()
,很认真地对待这样的请求,但每个方法不是一定要对中断作出响应。对于中断请求,不阻塞但是仍然要花较长时间执行的方法可以轮询中断状态,并在被中断的时候提前返回。 您可以随意忽略中断请求,但是这样做的话会影响响应。
中断的协作特性所带来的一个好处是,它为安全地构造可取消活动提供更大的灵活性。我们很少希望一个活动立即停止;如果活动在正在进行更新的时候被取消,那 么程序数据结构可能处于不一致状态。中断允许一个可取消活动来清理正在进行的工作,恢复不变量,通知其他活动它要被取消,然后才终止。
如果抛出 InterruptedException
意味着一个方法是阻塞方法,那么调用一个阻塞方法则意味着您的方法也是一个阻塞方法,而且您应该有某种策略来处理 InterruptedException
。通常最容易的策略是自己抛出 InterruptedException
,如清单 1 中 putTask()
和 getTask()
方法中的代码所示。 这样做可以使方法对中断作出响应,并且只需将 InterruptedException
添加到 throws 子句。
清单 1. 不捕捉 InterruptedException,将它传播给调用者
public class TaskQueue { private static final int MAX_TASKS = 1000; private BlockingQueue<Task> queue = new LinkedBlockingQueue<Task>(MAX_TASKS); public void putTask(Task r) throws InterruptedException { queue.put(r); } public Task getTask() throws InterruptedException { return queue.take(); } }
有时候需要在传播异常之前进行一些清理工作。在这种情况下,可以捕捉 InterruptedException
,执行清理,然后抛出异常。清单 2 演示了这种技术,该代码是用于匹配在线游戏服务中的玩家的一种机制。 matchPlayers()
方法等待两个玩家到来,然后开始一个新游戏。如果在一个玩家已到来,但是另一个玩家仍未到来之际该方法被中断,那么它会将那个玩家放回队列中,然后重新抛出 InterruptedException
,这样那个玩家对游戏的请求就不至于丢失。
清单 2. 在重新抛出 InterruptedException 之前执行特定于任务的清理工作
public class PlayerMatcher { private PlayerSource players; public PlayerMatcher(PlayerSource players) { this.players = players; } public void matchPlayers() throws InterruptedException { try { Player playerOne, playerTwo; while (true) { playerOne = playerTwo = null; // Wait for two players to arrive and start a new game playerOne = players.waitForPlayer(); // could throw IE playerTwo = players.waitForPlayer(); // could throw IE startNewGame(playerOne, playerTwo); } } catch (InterruptedException e) { // If we got one player and were interrupted, put that player back if (playerOne != null) players.addFirst(playerOne); // Then propagate the exception throw e; } } }
有时候抛出 InterruptedException
并不合适,例如当由 Runnable
定义的任务调用一个可中断的方法时,就是如此。在这种情况下,不能重新抛出 InterruptedException
,但是您也不想什么都不做。当一个阻塞方法检测到中断并抛出 InterruptedException
时,它清除中断状态。如果捕捉到 InterruptedException
但是不能重新抛出它,那么应该保留中断发生的证据,以便调用栈中更高层的代码能知道中断,并对中断作出响应。该任务可以通过调用 interrupt()
以 “重新中断” 当前线程来完成,如清单 3 所示。至少,每当捕捉到 InterruptedException
并且不重新抛出它时,就在返回之前重新中断当前线程。
清单 3. 捕捉 InterruptedException 后恢复中断状态
public class TaskRunner implements Runnable { private BlockingQueue<Task> queue; public TaskRunner(BlockingQueue<Task> queue) { this.queue = queue; } public void run() { try { while (true) { Task task = queue.take(10, TimeUnit.SECONDS); task.execute(); } } catch (InterruptedException e) { // Restore the interrupted status Thread.currentThread().interrupt(); } } }
处理 InterruptedException
时采取的最糟糕的做法是生吞它 —— 捕捉它,然后既不重新抛出它,也不重新断言线程的中断状态。对于不知如何处理的异常,最标准的处理方法是捕捉它,然后记录下它,但是这种方法仍然无异于生吞中断,因为调用栈中更高层的代码还是无法获得关于该异常的信息。(仅仅记录 InterruptedException
也不是明智的做法,因为等到人来读取日志的时候,再来对它作出处理就为时已晚了。) 清单 4 展示了一种使用得很广泛的模式,这也是生吞中断的一种模式:
// Don't do this public class TaskRunner implements Runnable { private BlockingQueue<Task> queue; public TaskRunner(BlockingQueue<Task> queue) { this.queue = queue; } public void run() { try { while (true) { Task task = queue.take(10, TimeUnit.SECONDS); task.execute(); } } catch (InterruptedException swallowed) { /* DON'T DO THIS - RESTORE THE INTERRUPTED STATUS INSTEAD */ } } }
如果不能重新抛出 InterruptedException
,不管您是否计划处理中断请求,仍然需要重新中断当前线程,因为一个中断请求可能有多个 “接收者”。标准线程池 (ThreadPoolExecutor
)worker 线程实现负责中断,因此中断一个运行在线程池中的任务可以起到双重效果,一是取消任务,二是通知执行线程线程池正要关闭。如果任务生吞中断请求,则 worker 线程将不知道有一个被请求的中断,从而耽误应用程序或服务的关闭。
语言规范中并没有为中断提供特定的语义,但是在较大的程序中,难于维护除取消外的任何中断语义。取决于是什么活动,用户可以通过一个 GUI 或通过网络机制,例如 JMX 或 Web 服务来请求取消。程序逻辑也可以请求取消。例如,一个 Web 爬行器(crawler)如果检测到磁盘已满,它会自动关闭自己,否则一个并行算法会启动多个线程来搜索解决方案空间的不同区域,一旦其中一个线程找到一 个解决方案,就取消那些线程。
仅仅因为一个任务是可取消的,并不意味着需要立即 对中断请求作出响应。对于执行一个循环中的代码的任务,通常只需为每一个循环迭代检查一次中断。取决于循环执行的时间有多长,任何代码可能要花一些时间才能注意到线程已经被中断(或者是通过调用 Thread.isInterrupted()
方法轮询中断状态,或者是调用一个阻塞方法)。 如果任务需要提高响应能力,那么它可以更频繁地轮询中断状态。阻塞方法通常在入口就立即轮询中断状态,并且,如果它被设置来改善响应能力,那么还会抛出 InterruptedException
。
惟一可以生吞中断的时候是您知道线程正要退出。只有当调用可中断方法的类是 Thread
的一部分,而不是 Runnable
或通用库代码的情况下,才会发生这样的场景,清单 5 演示了这种情况。清单 5 创建一个线程,该线程列举素数,直到被中断,这里还允许该线程在被中断时退出。用于搜索素数的循环在两个地方检查是否有中断:一处是在 while 循环的头部轮询 isInterrupted()
方法,另一处是调用阻塞方法 BlockingQueue.put()
。
public class PrimeProducer extends Thread { private final BlockingQueue<BigInteger> queue; PrimeProducer(BlockingQueue<BigInteger> queue) { this.queue = queue; } public void run() { try { BigInteger p = BigInteger.ONE; while (!Thread.currentThread().isInterrupted()) queue.put(p = p.nextProbablePrime()); } catch (InterruptedException consumed) { /* Allow thread to exit */ } } public void cancel() { interrupt(); } }
并非所有的阻塞方法都抛出 InterruptedException
。输入和输出流类会阻塞等待 I/O 完成,但是它们不抛出 InterruptedException
,而且在被中断的情况下也不会提前返回。然而,对于套接字 I/O,如果一个线程关闭套接字,则那个套接字上的阻塞 I/O 操作将提前结束,并抛出一个 SocketException
。java.nio
中的非阻塞 I/O 类也不支持可中断 I/O,但是同样可以通过关闭通道或者请求 Selector
上的唤醒来取消阻塞操作。类似地,尝试获取一个内部锁的操作(进入一个 synchronized
块)是不能被中断的,但是 ReentrantLock
支持可中断的获取模式。
有些任务拒绝被中断,这使得它们是不可取消的。但是,即使是不可取消的任务也应该尝试保留中断状态,以防在不可取消的任务结束之后,调用栈上更高层的代码 需要对中断进行处理。清单 6 展示了一个方法,该方法等待一个阻塞队列,直到队列中出现一个可用项目,而不管它是否被中断。为了方便他人,它在结束后在一个 finally 块中恢复中断状态,以免剥夺中断请求的调用者的权利。(它不能在更早的时候恢复中断状态,因为那将导致无限循环 —— BlockingQueue.take()
将在入口处立即轮询中断状态,并且,如果发现中断状态集,就会抛出 InterruptedException
。)
public Task getNextTask(BlockingQueue<Task> queue) { boolean interrupted = false; try { while (true) { try { return queue.take(); } catch (InterruptedException e) { interrupted = true; // fall through and retry } } } finally { if (interrupted) Thread.currentThread().interrupt(); } }
您可以用 Java 平台提供的协作中断机制来构造灵活的取消策略。各活动可以自行决定它们是可取消的还是不可取消的,以及如何对中断作出响应,如果立即返回会危害应用程序完整性的话,它们还可以推迟中断。即使您想在代码中完全忽略中断,也应该确保在捕捉到 InterruptedException
但是没有重新抛出它的情况下,恢复中断状态,以免调用它的代码无法获知中断的发生。
相关推荐
处理 InterruptedException 在 Java 语言中,有很多方法可以抛出 InterruptedException,例如 Thread.sleep() 和 Object.wait()。这些方法都是阻塞方法,它们的完成取决于外部事件,而不是简单地运行完成任务。...
在Java编程中,`InterruptedException`是一个特殊的异常类型,主要用于处理线程中断的情况。当你在代码中调用诸如`Thread.sleep()`, `Thread.join()`, 或 `Object.wait()`等阻塞方法时,如果线程被中断,这些方法会...
// 处理InterruptedException } finally { // 终于代码 } ``` 此外,`throws`关键字用于方法签名,表示该方法可能会抛出异常,将异常处理的责任转移给调用者。这适用于检查性异常,而不是运行时异常。 在编写异常...
在`InterruptedException`的处理中,程序员需要考虑如何适当地响应中断请求,这可能是关闭资源,清理状态,或者停止当前的任务执行。 **线程中断的原理:** 线程中断并不是立即停止线程执行,而是在线程的状态中...
3. **捕获并处理InterruptedException**:对于那些会抛出`InterruptedException`的方法,我们通常需要在`try-catch`块中捕获它。捕获后,可以清除中断标志(因为这些方法会自动清除),然后根据需要处理中断情况,...
6. `interrupt()`:中断线程,线程内部需要处理InterruptedException。 7. `wait()`和`notify()`/`notifyAll()`:用于线程间同步,使得线程进入对象的等待池,等待被唤醒。 在实际编程中,`sleep()`方法常用于让...
7. **线程中断与异常处理**:如何通过interrupt()方法中断线程,以及如何处理InterruptedException。 8. **死锁与活锁**:线程间的相互等待可能导致死锁,理解死锁的概念和避免策略;活锁则是线程不断重试导致无法...
4. 线程中断:通过Thread类的interrupt()方法可以中断一个线程,但需要注意处理InterruptedException,尤其是在阻塞操作中。 5. 线程通信:使用wait(), notify(), notifyAll()方法可以在特定条件下控制线程间的协作...
例如,调用wait()、sleep()和notify()方法时,都要处理InterruptedException异常。 这些知识点是Java线程编程的基础,它们构成了Java并发编程的骨架,帮助开发者编写出稳定和高效的多线程应用程序。在实际开发中,...
响应线程中断应正确处理InterruptedException异常,不应简单地忽略或重新抛出。创建线程时要注意提供线程名,否则在多线程环境中排查问题时会非常困难。 在多线程编程中,还应当避免创建不必要的线程,因为线程的...
正确处理InterruptedException,可以使程序在必要时优雅地终止线程。 这个"Java多线程编程核心技术_完整版.pdf"教程应该涵盖了上述所有知识点,深入学习后,你将能够熟练地运用Java进行多线程编程,解决实际开发中...
8. **中断与异常**:线程可以通过interrupt()方法发送中断信号,以及如何处理InterruptedException。 9. **守护线程(Daemon)**:守护线程不会阻止程序退出,常用于后台服务。 10. **线程本地存储(ThreadLocal)...
该方法使用try-catch语句来处理InterruptedException异常。 2. 分数的计算:游戏中使用了两个变量`number`和`sum`来记录当前抽取的牌和总分数。每次抽取牌时,将当前牌的数值累加到总分数中。 3. 游戏的判定:游戏...
- 考虑异常处理,确保在中断或异常发生时线程能够正确地响应,例如使用try-catch块处理InterruptedException。 - 对于超时机制,需要合理设置超时时间,以防止线程过早或过晚地放弃等待。 - 当多个线程等待同一个...
j-concurrent 00 IBM developerWorks 中国 : Java 多线程与并发编程专题 ...36 Java 理论与实践 处理 InterruptedException.mht 37 Java 理论与实践 正确使用 Volatile 变量.mht 38 使用泛型和并发改善集合.mht
- **处理InterruptedException**:如果线程在等待状态(例如调用`sleep()`、`wait()`等方法)时被中断,将会抛出`InterruptedException`。因此,在调用这些方法之前最好检查线程的中断状态。 #### 三、线程优先级 ...
16. **避免使用Thread.sleep()无异常捕获**:始终在sleep()后使用try-catch,处理InterruptedException。 17. **线程安全**:在多线程环境中,注意同步访问共享资源,使用synchronized关键字。 18. **避免使用...
在并发编程中,正确处理InterruptedException是至关重要的。 以上就是Java并发编程的一些核心知识点。在实际开发中,熟练掌握这些概念和技巧,可以编写出高效、稳定的并发程序,提升系统的整体性能。在不断学习和...