当前位置：首页 > news >正文

[Java 并发编程] Thread 类

news 2026/8/13 10:24:12

Thread 类

1. Interrupt

在 Java 中，我们不能随意地中断一个线程，因为我们不清楚这个线程的运行状态，它可能持有锁，如果强行中断它可能会导致锁不能被释放的问题。或者可能正在操作数据库，强行中断可能出现数据不一致的情况。因此，Interrupt方法实际上是为目标线程设置一个中断状态，而不是真的中断其运行，目标线程的具体退出时机由其自己决定。

如果目标线程处于运行状态，则不会受任何影响，只是状态被标记为中断，目标线程需调用isInterrupted()来监听这个状态，从而响应中断信号。

如果目标线程处于阻塞状态（wait()、join()、sleep()），肯定就不能监听中断标记了，那么如何告知目标线程被中断呢，Java 在这里的处理方法是使这些可被中断的阻塞方法抛出InterruptedException，当然也会将其标记为中断。例如：

publicclassTransactionManager{// 该方法会尝试提交事务，如果提交失败（抛出 CommitException）会进行重试，最多重试 MAX_RETRIES 次。// 每次重试间隔 1 秒。如果在等待期间被中断则抛出 InterruptedException。publicbooleancommitWithRetry()throwsInterruptedException{for(inti=0;i<MAX_RETRIES;i++){try{returndoCommit();}catch(CommitExceptione){if(i==MAX_RETRIES-1)throwe;Thread.sleep(1000);}}returnfalse;}}// 调用方：try{transactionManager.commitWithRetry();}catch(InterruptedExceptione){transactionManager.rollback();// 执行回滚Thread.currentThread().interrupt();// 重新设置中断状态throwe;// 继续向上传递}

这里的关键是，必须将中断信号一直传递下去（捕获InterruptedException会清除中断标记），也就是让上层代码能够感知线程的中断。这个信号的传递方式，可以是上抛异常，也可以是重新设置中断状态，也可以是抛出自定义的业务异常，这主要看上层代码是怎样响应中断信号的，但出于防御性编程的思想我们要尽量多做一些事情，这意味着：

如果在当前层无需做任何处理，直接上抛，此时中断状态未清除。

如果在当前层需要 catch 然后进行收尾处理，那么建议无论如何要调用interrupt()重新设置中断状态，并抛出自定义的业务异常，这样可以保证上层代码对中断的感知，无论其选择监听中断信号还是捕获异常。