Как дождаться окончания процессов Java AWS Lambda

Question

Я хочу подождать, пока мои процессы не закончатся, прежде чем я верну свой речевой ответ, в противном случае мне кажется, что он отключает мой процесс и, следовательно, не завершает его, я действительно верю, что он может заморозить процесс, но это не мое желание.

Как мне ждать?

@Override
public SpeechletResponse onIntent(SpeechletRequestEnvelope<IntentRequest> requestEnvelope) {
    IntentRequest request = requestEnvelope.getRequest();

    Intent intent = request.getIntent();
    String intentName = (intent != null) ? intent.getName() : null;

    if (intentName == null) return null;

    switch (intentName) {
        case IntentTitle.NEW_TICKET:

            switch (request.getDialogState()) {
                case STARTED:
                    return Response.getDialogueResponse(intent, true);
                case IN_PROGRESS:
                    return Response.getDialogueResponse(intent, false);
                case COMPLETED:
                    String numberString = intent.getSlot(SlotTitle.ID).getValue();
                    if (!NumberUtils.isCreatable(numberString)) return Response.ERROR;

                    Member member = Info.GUILD.getMemberById(numberString);
                    User sender = UserDB.getUser(member);

                    CommissionTicket commissionTicket = new CommissionTicket(sender);
                    commissionTicket.create();

                    //wait until processes finish before continuing

                    return Response.NEW_TICKED_CREATED;
            }
    }

    return null;
}

ОБНОВЛЕНИЕ: Посмотрел журналы CloudWatch, и, ну, в общем, то, что я ожидал, происходит ..Посмотрите время для этих журналов (я запустил их 3 раза, поэтому записано 3 разных времени, но кроме одного и того же сеанса лямбды)

public void create() {
    System.out.println("log2");
    GuildController guildController = Info.GUILD.getController();

    guildController.createTextChannel(ticketType.name().toLowerCase() + "-" + creator.getName() + "-" + id.value()).queue(channel -> {
        System.out.println("log3");
                ChannelManager channelManager = channel.getManager();
                GuildManager guildManager = channelManager.getGuild().getManager();
                List<Member> members = guildManager.getGuild().getMembers();
                List<Member> admins = new ArrayList<>();

                for (Member member : members) {
                    for (Role role : member.getRoles()) {
                        if (!role.getName().equalsIgnoreCase(Info.ADMIN_STRING)) continue;
                        admins.add(member);
                    }
                }
        System.out.println("log4");
                for (Member member : members) {
                    if (member.equals(creator.getMember())) continue;
                    channel.createPermissionOverride(member).setDeny(Permission.MESSAGE_READ).queue();
                }
        System.out.println("log5");

                for (Member admin : admins) {
                    if (admin.equals(creator.getMember())) continue;
                    channel.createPermissionOverride(admin).setAllow(Permission.MESSAGE_READ).queue();
                }
        System.out.println("log6");

                BotMessage botMessage = new BotMessage();
                botMessage
                        .setTitle("New Ticket! User: " + creator.getName())
                        .setColour(Color.CYAN)
                        .setDescription("Please enter your full request here! \n" +
                                "Make sure to let us know whether you are looking for a quote/timeframe,\n" +
                                "or have a budget in mind, and we will work around you!\n\n" +
                                "A sales representative will be with you as soon as possible!")
                        .send((TextChannel) channel);
        System.out.println("log7");

                this.textChannel = (TextChannel) channel;

                TicketDB.addTicket(this);
        System.out.println("log8");
            }
    );

Журналы:

https://gyazo.com/0ad2baa8d1438be8364dd1112159c4f4 https://gyazo.com/e197f33335046afe3c9f8f1ace267d30

ОБНОВЛЕНИЕ Реализован класс Future, работал, но все еще немного глючит.Теперь он полностью создает тикет, и это здорово, однако, когда я снова отправляю тот же вызов, он по какой-то причине отправляет сообщение в том же канале, прежде чем создать следующий тикет.

Итак,для имитации ...

вызов функции через AWS Lambda

создание билета полностью

повторный вызов функции через AWS Lambda

отправка одного или двух сообщений вканал предыдущих билетов

Полностью создает новый билет

https://gyazo.com/dc6e4391f4964f41a73f1c3be92190f9

@Override
public SpeechletResponse onIntent(SpeechletRequestEnvelope<IntentRequest> requestEnvelope) {
    IntentRequest request = requestEnvelope.getRequest();

    Intent intent = request.getIntent();
    String intentName = (intent != null) ? intent.getName() : null;

    if (intentName == null) return null;

    switch (intentName) {
        case IntentTitle.NEW_TICKET:

            switch (request.getDialogState()) {
                case STARTED:
                    return Response.getDialogueResponse(intent, true);
                case IN_PROGRESS:
                    return Response.getDialogueResponse(intent, false);
                case COMPLETED:
                    String numberString = intent.getSlot(SlotTitle.ID).getValue();
                    if (!NumberUtils.isCreatable(numberString)) return Response.ERROR;

                    Member member = Info.GUILD.getMemberById(numberString);
                    User sender = UserDB.getUser(member);

                    System.out.println("log1");

                    Future<Ticket> commissionTicket = new CommissionTicket(sender).create();
                    try {
                        commissionTicket.get(10000, TimeUnit.MILLISECONDS);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }

                    //wait until processes finish before continuing

                    return Response.NEW_TICKED_CREATED;
            }
    }

    return null;
}

В классе билетов:

public Future<Ticket> create() {
    System.out.println("log2");
    GuildController guildController = Info.GUILD.getController();
    RequestFuture<Channel> channelRequestFuture = guildController.createTextChannel(ticketType.name().toLowerCase() + "-" + creator.getName() + "-" + id.value()).submit();
    try {
        Channel channel = channelRequestFuture.get(10000, TimeUnit.MILLISECONDS);
                    System.out.println("log3");
        ChannelManager channelManager = channel.getManager();
        GuildManager guildManager = channelManager.getGuild().getManager();
        List<Member> members = guildManager.getGuild().getMembers();
        List<Member> admins = new ArrayList<>();

        for (Member member : members) {
            for (Role role : member.getRoles()) {
                if (!role.getName().equalsIgnoreCase(Info.ADMIN_STRING)) continue;
                admins.add(member);
            }
        }
        System.out.println("log4");
        for (Member member : members) {
            if (member.equals(creator.getMember())) continue;
            channel.createPermissionOverride(member).setDeny(Permission.MESSAGE_READ).queue();
        }
        System.out.println("log5");

        for (Member admin : admins) {
            if (admin.equals(creator.getMember())) continue;
            channel.createPermissionOverride(admin).setAllow(Permission.MESSAGE_READ).queue();
        }
        System.out.println("log6");

        BotMessage botMessage = new BotMessage();
        botMessage
                .setTitle("New Ticket! User: " + creator.getName())
                .setColour(Color.CYAN)
                .setDescription("Please enter your full request here! \n" +
                        "Make sure to let us know whether you are looking for a quote/timeframe,\n" +
                        "or have a budget in mind, and we will work around you!\n\n" +
                        "A sales representative will be with you as soon as possible!")
                .send((TextChannel) channel);
        System.out.println("log7");

        this.textChannel = (TextChannel) channel;

        TicketDB.addTicket(this);
        System.out.println("log8");
        Future<Ticket> future = ConcurrentUtils.constantFuture(this);
        return future;
    } catch (Exception e) {
        e.printStackTrace();
    }

    if (!userIsInTicket(creator)) users.add(creator);
    return null;

}

Answer 1

Я не уверен, что происходит внутри commissionTicket.create(); (я предполагаю, что это ваш код, а не часть какой-то библиотеки, и что он каким-то образом работает асинхронно), но одним из решений было бы, чтобы этот метод возвращал Future<>объект, а затем ждать на нем, чтобы закончить.Что-то вроде:

Future<CommissionTicket> commissionTicketFuture = CommissionTicket.create(sender);
commissionTicketFuture.get(SOME_TIMEOUT, TimeUnit.MILLIS);
return Response.NEW_TICKET_CREATED;