public void waitFor() throws InterruptedException {
    try {
      myFinishedFuture.get();
    }
    catch (ExecutionException e) {
      if (!(e.getCause() instanceof ControlFlowException)) {
        LOG.error(e);
      }
    }
  }
public void waitFor()