Java中断异常的正确处理方法

Java中断异常（Interrupted Exception）是指在程序运行过程中，通过调用Thread.interrupt()方法，向正在运行的线程发出一个中断信号，该信号可以被捕获并响应，以进行线程的安全停止或其他处理。对于Java应用程序开发者来说，合理应对线程中的中断异常是非常重要的技能。下面是Java中断异常的正确处理方法的攻略：

1. 感知中断信号

在编写Java多线程代码时，应该采用一个while循环来检测线程是否被中断，以及如何处理异常：

while(!Thread.currentThread().isInterrupted()) {
    try {
        // 线程运行的代码
    } catch (InterruptedException e) {
        // 处理中断异常的代码
    }
}

这段代码的核心是：当中断信号到达时，线程会抛出InterruptedException异常，从而跳出循环，停止线程的执行。因此，应该在此处提供如何处理中断的异常的代码逻辑。

2. 停止线程的执行

中断异常可以被用来停止线程的执行。例如，如果我们正在编写一个类似于JAVA虚拟机的应用程序，我们可以定义一个Thread类的子类来管理线程的状态，如下所示：

class JVMThread extends Thread {
    public void run() {
        while(!Thread.currentThread().isInterrupted()) {
            // 执行线程所需的任务
        }
        // 停止线程的执行
    }
    public void shutdown() {
        // 中断线程执行
        interrupt();
    }
}

在shutdown()方法中，我们调用Thread.interrupt()方法中断线程的执行，从而导致run()方法跳出while循环，线程被正常地停止执行。

3. 处理中断异常

对于常见的I/O操作，Java提供了标准的实现来处理InterruptedException异常。下面是一个示例程序，演示如何正确处理中断异常：

try {
    while(buffer.hasRemaining()) {
        if(channel.write(buffer) == 0) {
            buffer.compact();
            channel.read(buffer);
            buffer.flip();
        }
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    // 记录异常信息
} finally {
    buffer.compact();
}

在此代码中有一个while循环，它执行了I/O操作来写入缓冲区。如果操作没有完成，那么while循环会继续执行，直到中断信号到达。当发生中断异常时，我们通过调用Thread.currentThread().interrupt()方法来重置中断状态，并记录异常的信息。在finally代码段中，最后对缓冲区进行清理操作，确保程序正常结束。

4. 使用wait和notify

Java的wait和notify方法可以协作使用以响应线程中的中断信号。在下面的示例程序中，我们使用wait和notify方法来管理一个线程队列，以便正确停止和启动线程。

class TaskQueue {
    private Set<Task> tasks = new HashSet<>();
    public synchronized void addTask(Task t) {
        tasks.add(t);
        // 唤醒等待的线程
        notifyAll();
    }
    public synchronized Task getTask() throws InterruptedException {
        while(tasks.size() == 0) {
            // 等待新任务的到来
            wait();
        }
        // 删除并返回第一个任务
        return tasks.iterator().next();
    }
    public synchronized void cancel() {
        // 停止所有线程的执行
        for(Task t : tasks) {
            t.interrupt();
        }
    }
}

class Task extends Thread {
    private TaskQueue queue;
    public Task(TaskQueue queue) {
        this.queue = queue;
    }
    public void run() {
        while(!isInterrupted()) {
            try {
                Task t = queue.getTask();
                t.execute();
            } catch (InterruptedException e) {
                // 处理中断异常
            }
        }
    }
    public void execute() {
        // 执行任务的代码
    }
    public void shutdown() {
        interrupt();
    }
}

在此代码中，我们创建了一个TaskQueue类，用于管理由Task队列组成的集合。getTask()方法使调用线程等待任务队列中的任务，并在队列为空时列入睡眠状态，直到有新任务加入队列。当有新任务加入时，通过notifyAll()方法唤醒一个正在等待的线程，以处理任务。

cancel()方法通过中断所有任务来取消任务队列的执行。Task类是一个线程类，它从TaskQueue获取并执行任务，直到线程被中断。如果线程被中断，则Task.getTask()方法会抛出InterruptedException异常，以取消正在进行的操作，并在Task.run()方法中重新处理异常。通过这种方式，Task可以正确地处理中断异常，并在任务队列中正确地停止线程的执行。

以上，就是Java中断异常的正确处理方法的完整攻略。