Java中断异常 InterruptedException 的正确处理方式

2023年10月16日 167次阅读 来源: 后端开发

你看到这篇文件可能是因为你已经调用了一个抛出 InterruptedException 异常的方法，并且需要以某种方式处理它。

首先，需要了解为一个方法为啥会 throws InterruptedException, 是这个方法抛出中断异常作为方法签名的一部分以及调用正在调用的方法的可能结果。因此，首先要接受一个事实，InterruptedException 是这个方法调用的完全有效的结果。

现在，如果你正在调用的方法抛出此类异常，你的方法应该怎么做？可以通过考虑以下问题找出答案：

你正在实现的方法是否有意义抛出异常 InterruptedException？换句话说，InterruptedException 异常是否是调用你的方法是一个明智的结果？

  • 如果是，那么 throws InterruptedException 应当成为你的方法签名，你应该让异常传播（即不捕获该异常的话）。

示例： 你的方法等待来自网络的值以完成计算并返回结果。如果阻塞网络调用抛出 InterruptedException方法无法以正常方式完成计算。你让 InterruptedException 传播。

int computeSum(Server server) throws InterruptedException {
    // Any InterruptedException thrown below is propagated
    int a = server.getValueA();
    int b = server.getValueB();
    return a + b;
}
  • 如果不是，那么你不应该声明你的方法 throws InterruptedException, 你应该（必须！）捕获异常。在这种情况下，现在要记住两件事：
  1. 有人打断了你的线程。这个人可能急于取消操作，优雅地终止程序，或者其他什么。你应该对那个人保持礼貌并且不用再费力地从你的方法中返回。
  2. 即使你的方法可以设法让出现 InterruptedException 异常时, 即在线程被中断的情况下, 产生合理的返回值，线程被中断过这件事仍然很重要。特别是，调用方法的代码可能会对执行方法期间是否发生中断感兴趣。您应该通过设置中断标志来记录发生中断的事实：即需要在 catch 里调用Thread.currentThread().interrupt() .

示例： 用户要求打印两个值的总和。如果无法计算总和，则打印“无法计算总和”（并且比由于一个导致程序因堆栈跟踪而崩溃要好得多 InterruptedException）。换句话说，用这个方法声明这个方法是没有意义的throws InterruptedException。

void printSum(Server server) {
    try {
        int sum = computeSum(server);
        System.out.println("Sum: " + sum);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();  // set interrupt flag
        System.out.println("Failed to compute sum");
    }
}

到目前为止，应该清楚的是，做这件事throw new RuntimeException(e)是一个坏主意。这对调用者来说不太礼貌。您可以发明一个新的运行时异常，但根本原因（某人希望线程停止执行）可能会丢失。

另一个例子：实施 Runnable
正如您可能已经发现的那样，签名 Runnable.run 不允许重新抛出 InterruptedExceptions。好吧，你声明了实现 Runnable 接口，这意味着你已声明处理可能的中断异常问题。选择不同的接口，例如Callable则可以抛出中断异常(V call() throws Exception)，或者按照说的上面的第二种方法。

还有一个：调用 Thread.sleep
你正在尝试读取文件，规范说你应该尝试10次，间隔1秒。调用 Thread.sleep(1000)。所以，你需要处理 InterruptedException。对于一种方法 tryToReadFile 来说，如果说“如果我被打断了，我无法完成尝试阅读文件的行为”这一方法非常有意义。换句话说，它对抛出的方法很有意义InterruptedExceptions。

String tryToReadFile(File f) throws InterruptedException {
    for (int i = 0; i < 10; i++) {
        if (f.exists())
            return readFile(f);
        Thread.sleep(1000);
    }
    return null;
}

作者:

Andreas Lundblad，理论计算机科学博士。在Oracle开发Java平台（javac，javadoc，sjavac）工作了三年。安德烈亚斯是StackOverflow的Java标签的前10贡献者.

    原文作者：后端开发
    原文地址: https://segmentfault.com/a/1190000017314625
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞