Java 中断异常的正确处理方式(二)

简介: 这个故事可能很熟悉:你正在写一个测试程序,你需要暂停某个线程一段时间,所以你调用 Thread.sleep()。然后编译器或 IDE 就会抱怨说 InterruptedException 没有抛出声明或捕获。什么是 InterruptedException,你为什么要处理它?最常见的响应 InterruptedException 做法是吞下它 - 捕获它并且什么也不做(或者记录它,也没好多少) - 正如我们将在清单4中看到的那样。不幸的是,这种方法抛弃了关于中断发生的重要信息,这可能会损害应用程序取消活动或响应及时关闭的能力。

不要吞下中断

有时抛出 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) { 
             //重要: 恢复中断状态
             Thread.currentThread().interrupt();
         }
    }
}


你可以做的最糟糕的事情 InterruptedException 就是吞下它 - 抓住它,既不重新抛出它也不重新确定线程的中断状态。处理你没有规划的异常的标准方法 - 捕获它并记录它 - 也算作吞噬中断,因为调用堆栈上的代码将无法找到它。(记录 InterruptedException 也很愚蠢,因为当人类读取日志时,对它做任何事都为时已晚。)清单4显示了吞下中断的常见模式:

清单4.吞下中断 - 不要这样做

// 不要这么做!
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)工作线程实现响应中断,因此中断线程池中运行的任务可能具有取消任务和通知执行线程线程池正在关闭的效果。如果作业吞下中断请求,则工作线程可能不会知道请求了中断,这可能会延迟应用程序或服务关闭。


实施可取消的任务

语言规范中没有任何内容给出任何特定语义的中断,但在较大的程序中,除了取消之外,很难保持中断的任何语义。根据活动,用户可以通过 GUI 或通过 JMX 或 Web 服务等网络机制请求取消。它也可以由程序逻辑请求。例如,如果 Web 爬虫检测到磁盘已满,则可能会自动关闭自身,或者并行算法可能会启动多个线程来搜索解决方案空间的不同区域,并在其中一个找到解决方案后取消它们。


仅仅因为一个任务是取消并不意味着它需要一个中断请求响应立即。对于在循环中执行代码的任务,通常每次循环迭代仅检查一次中断。根据循环执行的时间长短,在任务代码通知线程中断之前可能需要一些时间(通过使用 Thread.isInterrupted()或通过调用阻塞方法轮询中断状态)。如果任务需要更具响应性,则可以更频繁地轮询中断状态。阻止方法通常在进入时立即轮询中断状态,InterruptedException 如果设置为提高响应性则抛出 。


吞下一个中断是可以接受的,当你知道线程即将退出时。这种情况只发生在调用可中断方法的类是一个 Thread,而不是 Runnable 一般或通用库代码的一部分时,如清单5所示。它创建一个枚举素数的线程,直到它被中断并允许线程退出中断。寻求主要的循环在两个地方检查中断:一次是通过轮询 isInterrupted() while 循环的头部中的方法,一次是在调用阻塞 BlockingQueue.put() 方法时。

清单5.如果你知道线程即将退出,则可以吞下中断

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。非阻塞 I/O 类 java.nio 也不支持可中断 I/O,但可以通过关闭通道或请求唤醒来类似地取消阻塞操作 Selector。同样,尝试获取内在锁(输入一个 synchronized 块)不能被中断,但 ReentrantLock 支持可中断的采集模式。


不可取消的任务

有些任务只是拒绝被打断,使它们无法取消。但是,即使是不可取消的任务也应该尝试保留中断状态,以但在调用堆栈上层的代码在非可取消任务完成后想要对发生的中断进行响应。清单6显示了一个等待阻塞队列直到某个项可用的方法,无论它是否被中断。为了成为一个好公民,它在完成后恢复最终块中的中断状态,以免剥夺呼叫者的中断请求。它无法提前恢复中断状态,因为它会导致无限循环 - BlockingQueue.take(), 完成后则可以在进入时立即轮询中断状态, 如果发现中断状态设置,则可以抛出InterruptedException。

清单6. 在返回之前恢复中断状态的非可执行任务

public Task getNextTask(BlockingQueue<Task> queue) {
    boolean interrupted = false;
    try {
        while (true) {
            try {
                return queue.take();
            } catch (InterruptedException e) {
                interrupted = true;
                // 失败了再试
            }
        }
    } finally {
        if (interrupted)
            Thread.currentThread().interrupt();
    }
}

摘要


你可以使用 Java 平台提供的协作中断机制来构建灵活的取消策略。作业可以决定它们是否可以取消,它们希望如何响应中断,如果立即返回会影响应用程序的完整性,它们可以推迟中断以执行特定于任务的清理。即使你想完全忽略代码中断,也要确保在捕获 InterruptedException 并且不重新抛出代码时恢复中断状态 ,以便调用它的代码能够发现中断。

相关文章
|
1月前
|
Java
在 Java 中捕获和处理自定义异常的代码示例
本文提供了一个 Java 代码示例,展示了如何捕获和处理自定义异常。通过创建自定义异常类并使用 try-catch 语句,可以更灵活地处理程序中的错误情况。
65 1
|
1月前
|
Java API 调度
如何避免 Java 中的 TimeoutException 异常
在Java中,`TimeoutException`通常发生在执行操作超过预设时间时。要避免此异常,可以优化代码逻辑,减少不必要的等待;合理设置超时时间,确保其足够完成正常操作;使用异步处理或线程池管理任务,提高程序响应性。
67 12
|
1月前
|
Java
在 Java 中,如何自定义`NumberFormatException`异常
在Java中,自定义`NumberFormatException`异常可以通过继承`IllegalArgumentException`类并重写其构造方法来实现。自定义异常类可以添加额外的错误信息或行为,以便更精确地处理特定的数字格式转换错误。
37 1
|
1月前
|
IDE 前端开发 Java
怎样避免 Java 中的 NoSuchFieldError 异常
在Java中避免NoSuchFieldError异常的关键在于确保类路径下没有不同版本的类文件冲突,避免反射时使用不存在的字段,以及确保所有依赖库版本兼容。编译和运行时使用的类版本应保持一致。
71 7
|
1月前
|
Java 编译器
如何避免在 Java 中出现 NoSuchElementException 异常
在Java中,`NoSuchElementException`通常发生在使用迭代器、枚举或流等遍历集合时,尝试访问不存在的元素。为了避免该异常,可以在访问前检查是否有下一个元素(如使用`hasNext()`方法),或者使用`Optional`类处理可能为空的情况。正确管理集合边界和条件判断是关键。
76 6
|
1月前
|
Java
Java异常捕捉处理和错误处理
Java异常捕捉处理和错误处理
64 1
|
1月前
|
Java 编译器 开发者
Java异常处理的最佳实践,涵盖理解异常类体系、选择合适的异常类型、提供详细异常信息、合理使用try-catch和finally语句、使用try-with-resources、记录异常信息等方面
本文探讨了Java异常处理的最佳实践,涵盖理解异常类体系、选择合适的异常类型、提供详细异常信息、合理使用try-catch和finally语句、使用try-with-resources、记录异常信息等方面,帮助开发者提高代码质量和程序的健壮性。
70 2
|
1月前
|
Java
如何在 Java 中处理“Broken Pipe”异常
在Java中处理“Broken Pipe”异常,通常发生在网络通信中,如Socket编程时。该异常表示写入操作的另一端已关闭连接。解决方法包括:检查网络连接、设置超时、使用try-catch捕获异常并进行重试或关闭资源。
111 5
|
1月前
|
存储 安全 Java
如何避免 Java 中的“ArrayStoreException”异常
在Java中,ArrayStoreException异常通常发生在尝试将不兼容的对象存储到泛型数组中时。为了避免这种异常,确保在操作数组时遵循以下几点:1. 使用泛型确保类型安全;2. 避免生类型(raw types)的使用;3. 在添加元素前进行类型检查。通过这些方法,可以有效防止 ArrayStoreException 的发生。
43 3
|
2月前
|
人工智能 Oracle Java
解决 Java 打印日志吞异常堆栈的问题
前几天有同学找我查一个空指针问题,Java 打印日志时,异常堆栈信息被吞了,导致定位不到出问题的地方。
45 2