AWS lambda函数未终止线程

Question

我编写了一个从 AWS lammda 函数执行的 java 代码。在我的用例中，我想在 lambda 函数终止之前编写一些通用日志。为了实现这一点，我创建了一个新线程来监视 lambda 函数的 RemainingTimeInMillis。如果它达到某个限制，我会写一些通用消息。 现在我的问题是，即使我终止了一个线程，它也没有终止。

public class Lambda implements RequestHandler<Map<String, String>, String> {
public String handleRequests(Map<String, String> parameters, Context context) {
    LambdaTimeoutCheck thread = null;
    thread = new LambdaTimeoutCheck(context, "applicationName");
        thread.setName(threadname);
        thread.setStopTimeout(true);
        thread.start();

        /* remaining function logic  */
        System.out.println("Lambda function starts"+thread.isAlive());

        thread.shutdown();

        System.out.println("Lambda function ends"+thread.isAlive());
        return "success"
}



package com.pearson.autobahn.autobahnsdkheartbeat;

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

public class LambdaTimeoutCheck extends Thread {

    private Context context;

    private String applicationName;

    private boolean isStopTimeout;


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

    @Override
    public void run() {
        
        while (isStopTimeout()) {

            if (context.getRemainingTimeInMillis() <= 1000) {
                
                context.getLogger().log("Request ID: " + context.getAwsRequestId() + " " + applicationName
                        + " function execution about to Timeout");
                setStopTimeout(false);
            } 
            }

        }
    }

    
    public void shutdown() {

        this.setStopTimeout(false);

    }

    
    public boolean isStopTimeout() {
        return isStopTimeout;
    }


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

}

thread.isAlive() 总是正确的，即使我关闭了一个线程。请任何人帮助我如何解决这个问题。

Answer 1

就像任何 Java 程序一样：如果您的主线程需要等待另一个线程完成，您应该在子线程上调用 join()。