Java中StructuredTaskScope.joinUntil为何无法终止永久运行的Callable？

核心原因 #

StructuredTaskScope的shutdown()方法不会强制中断任务线程，它仅标记作用域为关闭状态、拒绝新任务提交，并唤醒等待join的主线程。你的代码存在两个关键问题：

1. Thread.sleep()的InterruptedException被静默吞掉，导致中断信号无法传递
2. 无限循环while(true)没有检查线程中断状态，即使线程被中断也会持续运行

解决方案 #

要让任务在超时后终止，必须让Callable主动响应线程中断。以下是修改后的可运行代码：

Consumer<String> log = msg -> System.out.println("log -> " + msg);
Consumer<Duration> wait = duration -> {
    try {
        Thread.sleep(duration);
    } catch (InterruptedException e) {
        // 恢复线程中断状态，让上层逻辑感知到中断
        Thread.currentThread().interrupt();
        // 抛出异常终止等待流程
        throw new RuntimeException(e);
    }
};
Callable<String> callableBlocking = () -> {
    log.accept("fetchFail.callableBlocking.begin");
    // 循环前检查线程是否被中断
    while (!Thread.currentThread().isInterrupted()) {
        log.accept("fetchFail.callableBlocking.while");
        wait.accept(Duration.ofSeconds(1));
    }
    log.accept("fetchFail.callableBlocking.interrupted, exiting");
    return "interrupted";
};
var scope = new StructuredTaskScope.ShutdownOnFailure();
try {
    var future = scope.fork(callableBlocking);
    scope.joinUntil(Instant.now().plusSeconds(1));
    scope.throwIfFailed();
    log.accept("result: " + future.resultNow());
} catch (InterruptedException | TimeoutException | ExecutionException e) {
    log.accept(e.getClass().getName() + ":" + e.getMessage());
    if (e instanceof TimeoutException) {
        scope.shutdown();
        log.accept("INFO: shutdown triggered");
    }
} finally {
    scope.close();
}

修改要点说明 #

1. 不吞中断异常：在等待逻辑中捕获InterruptedException后，重新设置线程中断状态并抛出异常，确保中断信号能传递到外层循环
2. 循环检查中断状态：将while(true)改为while(!Thread.currentThread().isInterrupted())，每次循环前判断线程是否被中断，一旦触发中断就退出循环
3. 利用StructuredTaskScope的中断机制：调用shutdown()时，作用域会向所有任务线程发送中断信号，此时任务的中断检查逻辑会生效，从而终止运行

验证效果 #

修改后控制台输出会在INFO: shutdown triggered之后，打印fetchFail.callableBlocking.interrupted, exiting，随后任务停止运行，不会再持续输出循环日志。

内容的提问来源于stack exchange，提问作者Tugalsan Karabacak