* important for other reasons: run() can still be invoked concurrently in different threads,
       * even with the above null checks.)
       */
      timeoutFutureRef = null;
      if (delegate.isDone()) {
        timeoutFuture.setFuture(delegate);
      } else {
        try {
          @RetainedLocalRef ScheduledFuture<?> timer = timeoutFuture.timer;

      }

      message += "delay)";
    }
    // It's confusing to see a completed future in a timeout message; if isDone() returns false,
    // then we know it must have given a pending toString value earlier. If not, then the future
    // completed after the timeout expired, and the message might be success.
    if (isDone()) {
      throw new TimeoutException(message + " but future completed as timeout expired");
    }

 * previous callable has returned -- and, if the previous callable was an {@link AsyncCallable}, not
 * until the {@code Future} it returned is {@linkplain Future#isDone done} (successful, failed, or
 * cancelled).
 *
 * <p>This class serializes execution of <i>submitted</i> tasks but not any <i>listeners</i> of
 * those tasks.
 *

        ClosingFuture.submit(waiter.waitFor((ClosingCallable<String>) closer -> "value"), executor);
    ListenableFuture<?> statusFuture = closingFuture.statusFuture();
    waiter.awaitStarted();
    assertThat(statusFuture.isDone()).isFalse();
    waiter.awaitReturned();
    assertThat(getUninterruptibly(statusFuture)).isNull();
  }

  public void testStatusFuture_failure() throws Exception {
    ClosingFuture<String> closingFuture =

        ClosingFuture.submit(waiter.waitFor((ClosingCallable<String>) closer -> "value"), executor);
    ListenableFuture<?> statusFuture = closingFuture.statusFuture();
    waiter.awaitStarted();
    assertThat(statusFuture.isDone()).isFalse();
    waiter.awaitReturned();
    assertThat(getUninterruptibly(statusFuture)).isNull();
  }

  public void testStatusFuture_failure() throws Exception {
    ClosingFuture<String> closingFuture =

        }
      };

  public void testServiceStartStop() throws Exception {
    NullService service = new NullService();
    service.startAsync().awaitRunning();
    assertFalse(future.isDone());
    service.stopAsync().awaitTerminated();
    assertTrue(future.isCancelled());
  }

  private class NullService extends AbstractScheduledService {
    @Override

        }
      };

  public void testServiceStartStop() throws Exception {
    NullService service = new NullService();
    service.startAsync().awaitRunning();
    assertFalse(future.isDone());
    service.stopAsync().awaitTerminated();
    assertTrue(future.isCancelled());
  }

  private class NullService extends AbstractScheduledService {
    @Override

labels.design_configuration=Sayfa Tasarımı
labels.design_title_file_upload=Yüklenecek Dosya
labels.design_title_file=Dosya Yöneticisi
labels.design_file=Dosyayı Yükle
labels.design_file_name=Dosya Adı (isteğe bağlı)
labels.design_button_upload=Yükle
labels.design_file_title_edit=Sayfa Dosyasını Görüntüle
labels.design_edit_button=Düzenle
labels.design_download_button=İndir
labels.design_delete_button=Sil

        if (StringUtil.isNotBlank(name)) {
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
            final boolean isRole = entryDn.toLowerCase(Locale.ROOT).indexOf("ou=role") != -1;
            if (isRole) {
                if (fessConfig.isLdapRoleSearchRoleEnabled()) {
                    roleSet.add(systemHelper.getSearchRoleByRole(normalizePermissionName(name)));

    @SuppressWarnings("unchecked")
    LoadingValueReference<Object, Object> valueReference =
        (LoadingValueReference) newEntry.getValueReference();
    assertThat(valueReference.futureValue.isDone()).isFalse();
    startSignal.countDown();

    try {
      doneSignal.await();
    } catch (InterruptedException e) {
      throw new RuntimeException(e);
    }