Блокировка, пока все экземпляры EC2 не будут в определенном состоянии?

Question

Я написал функцию, которая должна блокировать, пока все экземпляры в списке не находятся в определенном состоянии, поэтому вот что у меня есть:

private void waitForInstanceState(List<String> instancesId, InstanceStateName state) {
    int numAchievedState = 0;

    while (numAchievedState != instancesId.size()) {

        numAchievedState = 0;

        DescribeInstanceStatusRequest describeRequest = new DescribeInstanceStatusRequest().withInstanceIds(instancesId);
        DescribeInstanceStatusResult instanceStatus = ec2.describeInstanceStatus(describeRequest);

        for (InstanceStatus status : instanceStatus.getInstanceStatuses()) {
            if (status.getInstanceState().getName().equals(state.toString())) {
                numAchievedState++;
            }
        }

        try {
            Thread.sleep(15000);
        } catch (InterruptedException ex) {
            Logger.getLogger(AmazonLibrary.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
}

Код, который вызывает вышеупомянутую функцию, похож начто:

public void startInstace(List<String> instancesId) {

    StartInstancesRequest startRequest = new StartInstancesRequest(instancesId);
    ec2.startInstances(startRequest);

    waitForInstanceState(instancesId, InstanceStateName.Running);

    System.out.println("The instance has been started");


}

Дело в том, что иногда описывающий запрос экземпляра возвращает значение NULL для InstanceStatus, что, я думаю, никогда не должно происходить, поскольку экземпляр в amazon всегда имеет состояние?Также при использовании в функции instanceRun она работает, а при запуске с InstanceStateName, установленной в Stopped, она не работает.Нет исключений или ошибок.

Answer 1

Следующие сделали работу:

 private void waitForInstanceState(List<String> instancesId, InstanceStateName state) {
        int numAchievedState = 0;

        while (numAchievedState != instancesId.size()) {

            try {
                Thread.sleep(15000);
            } catch (InterruptedException ex) {
                Logger.getLogger(AmazonLibrary.class.getName()).log(Level.SEVERE, null, ex);
            }

            numAchievedState = 0;

            DescribeInstancesRequest describeInstance = new DescribeInstancesRequest().withInstanceIds(instancesId);
            DescribeInstancesResult describeResult = ec2.describeInstances(describeInstance);
            List<Reservation> reservations = describeResult.getReservations();

            //different instances might be in different reservation requests
            //so we need to traverse those
            for (Reservation reservation : reservations) {
                List<Instance> instances = reservation.getInstances();
                for (Instance instance : instances) {
                    if (instance.getState().getName().equals(state.toString())) {
                        numAchievedState++;
                    }
                }
            }
        }
    }