AWS Lambda Java自定义超时监控线程调用shutdown后仍存活问题求助

• 停止标志位isStopTimeout无volatile修饰：Java内存模型中普通变量的修改不会立即同步到所有线程的工作内存，监控线程一直读取缓存的旧值，无法感知到shutdown方法对标志位的修改，导致死循环无法退出。
• while循环无等待空转：循环内没有任何休眠逻辑，既占用了100%的CPU资源，也会让JVM触发编译优化，将isStopTimeout()的读取操作直接优化为常量，彻底不会感知到变量更新。
• 主线程未等待线程退出：调用shutdown后立即打印isAlive状态，此时监控线程还没完成退出流程，返回结果自然为true。

1. 给isStopTimeout添加volatile修饰，保证多线程间变量修改的可见性，禁止JVM做过度优化。
2. 在while循环内添加短时间休眠（建议50~200ms，根据你的超时预警阈值调整），避免空转浪费CPU，同时留出变量同步的时间窗口。
3. 主线程调用shutdown后执行thread.join()，等待监控线程完全终止后再继续执行后续逻辑。
4. 补充线程中断判断逻辑，提升异常场景下的健壮性。

首先是监控线程类：

package com.pearson.autobahn.autobahnsdkheartbeat;

import com.amazonaws.services.lambda.runtime.Context;

public class LambdaTimeoutCheck extends Thread {
    private Context context;
    private String applicationName;
    // 添加volatile修饰保证可见性
    private volatile boolean isStopTimeout;

    public LambdaTimeoutCheck(Context context, String applicationName) {
        this.context = context;
        this.applicationName = applicationName;
    }

    @Override
    public void run() {
        while (isStopTimeout() && !Thread.currentThread().isInterrupted()) {
            if (context.getRemainingTimeInMillis() <= 1000) {
                context.getLogger().log("Request ID: " + context.getAwsRequestId() + " " + applicationName
                        + " function execution about to Timeout");
                setStopTimeout(false);
                break;
            }
            try {
                // 每次循环休眠100ms，避免空转
                Thread.sleep(100);
            } catch (InterruptedException e) {
                // 收到中断信号直接退出
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    public void shutdown() {
        this.setStopTimeout(false);
        // 线程还在运行时直接中断，加快退出速度
        this.interrupt();
    }

    public boolean isStopTimeout() {
        return isStopTimeout;
    }

    public void setStopTimeout(boolean isStopTimeout) {
        this.isStopTimeout = isStopTimeout;
    }
}

然后是Lambda调用部分：

public class Lambda implements RequestHandler<Map<String, String>, String> {
    public String handleRequests(Map<String, String> parameters, Context context) {
        String threadname = "timeout-monitor-thread"; // 补充原代码缺失的变量定义
        LambdaTimeoutCheck thread = new LambdaTimeoutCheck(context, "applicationName");
        thread.setName(threadname);
        thread.setStopTimeout(true);
        thread.start();

        /* 剩余业务逻辑 */
        System.out.println("Lambda function starts"+thread.isAlive());

        thread.shutdown();
        try {
            // 等待监控线程最多1s完全退出
            thread.join(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        System.out.println("Lambda function ends"+thread.isAlive()); // 此时输出为false
        return "success"; // 补充原代码缺失的分号
    }
}

内容的提问来源于stack exchange，提问作者PS Kumar