Выполните итерацию всех машин в цикле for параллельно и проверьте, работают они или нет? - PullRequest
Новая
       22

Выполните итерацию всех машин в цикле for параллельно и проверьте, работают они или нет?

0 голосов
/ 29 мая 2018

У меня есть список машин в ArrayList.Я проверяю, работают ли все эти машины, или нет, поэтому я делаю http-вызов на них, и если они отвечают, что они работают, но если они не отвечают, то они не работают.Я считал их мертвыми, если они не отвечают в течение 10 попыток, то есть для каждой машины я повторяю 10 раз, если они не отвечают.

Теперь мне нужно выполнить итерацию этого списка hostnames параллельно в цикле for, поэтомуЯ пришел с кодом ниже.Есть ли проблемы с многопоточностью или что-то здесь можно улучшить?Правильно ли я здесь использую службу executor? 

  private static final ExecutorService executorService = Executors.newFixedThreadPool(20);

  public static void main(String[] args) throws Exception {
    List<String> hostnames = new ArrayList<>();
    //.. populating hostnames

    List<Future<Void>> futures = new ArrayList<Future<Void>>();
    for (final String machine : hostnames) {
      Callable<Void> callable = new Callable<Void>() {
        public Void call() throws Exception {
          String url = "http://" + machine + ":8080/ruok";
          if (!checkServer(url)) {
            System.out.println("server down: " + machine);
          }
          return null;
        }
      };
      futures.add(executorService.submit(callable));
    }
    executorService.shutdown();
    for (Future<Void> future : futures) {
      future.get();
    }
    System.out.println("All done!");
  }

  private static boolean checkServer(final String url) {
    boolean isUp = false;
    int retry = 10;
    for (int i = 1; i <= retry; i++) {
      try {
        RestClient.getInstance().getClient().getForObject(url, String.class);
        isUp = true;
        break;
      } catch (Exception ex) {
        // log exception
      }
    }
    return isUp;
  }
...