理解与解决Java并发中的ThreadInterruptedException案例

原创 ╰+哭是因爲堅強的太久メ 2024-12-11 16:54 35阅读 0赞

在Java并发编程中，`ThreadInterruptedException`是一个特殊情况。当一个线程在等待某个条件满足时，如果该条件突然被中断（比如通过调用interrupt()方法），那么线程就会抛出`ThreadInterruptedException`。

下面是一个简单的例子：

```java
// 创建一个有中断能力的线程
public class InterruptableThread extends Thread {
    private boolean interrupted = false;

@Override
    public void run() {
        try {
            // 线程会等待一段时间，然后检查中断标志
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            interrupted = true;  // 设置中断标志
            e.printStackTrace();  // 打印异常信息
        }
        System.out.println("Thread ended, but interrupted: " + interrupted);  // 输出中断状态
    }

// 方法供外部线程调用，中断线程运行
    public void interrupt() {
        this.interrupted = true;  // 设置中断标志
        try {
            // 确保线程在中断后仍处于可控制状态
            synchronized (this) {
                this.notifyAll();  // 唤醒所有等待的线程
            }
        } catch (InterruptedException e) {
            // 如果再次发生中断，忽略它
            e.printStackTrace();
        }
    }
}

// 在外部创建一个中断线程
public class Main {
    public static void main(String[] args) {
        InterruptableThread thread = new InterruptableThread();  // 创建并启动线程

try {
            thread.join();  // 等待线程执行完毕
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Main thread finished, checking interrupted flag: " + thread.interrupted));  // 检查线程是否被中断
    }
}
```

在这个案例中，创建了一个名为`InterruptableThread`的线程。这个线程在运行时会检查是否有中断信号（`interrupt()`方法）。如果有中断，就会抛出`ThreadInterruptedException`。

在外部的`main`方法中，我们启动了这个线程，并等待它执行完毕。最后，检查线程是否被中断。