java - 阻塞直到所有 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");


}

问题是，有时描述实例请求会为 InstanceStatus 返回 null，我认为这种情况永远不会发生，因为亚马逊中的实例总是有一个状态？此外，当在 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++;
                    }
                }
            }
        }
    }