* }</pre>
   *
   * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
   * the discussion in the {@link ListenableFuture#addListener} documentation. All its warnings
   * about heavyweight listeners are also applicable to heavyweight functions passed to this method.
   *
   * <p>After calling this method, you may not call {@link #finishToFuture()}, {@link

    final Error error = new Error();
    final CountDownLatch latch = new CountDownLatch(1);
    TestService service = new TestService();
    service.addListener(
        new Service.Listener() {
          @Override
          public void running() {
            throw error;
          }

          @Override

    } finally {
      joinPool(e);
    }
  }

  private static void assertListenerRunImmediately(ListenableFuture<?> future) {
    CountingRunnable listener = new CountingRunnable();
    future.addListener(listener, directExecutor());
    assertEquals(1, listener.count);
  }

  private static final class CountingRunnable implements Runnable {
    int count;

    @Override
    public void run() {

    } finally {
      joinPool(e);
    }
  }

  private static void assertListenerRunImmediately(ListenableFuture<?> future) {
    CountingRunnable listener = new CountingRunnable();
    future.addListener(listener, directExecutor());
    assertEquals(1, listener.count);
  }

  private static final class CountingRunnable implements Runnable {
    int count;

    @Override
    public void run() {

      ListeningExecutorService executorService,
      Callable<T> task,
      final BlockingQueue<Future<T>> queue) {
    final ListenableFuture<T> future = executorService.submit(task);
    future.addListener(
        new Runnable() {
          @Override
          public void run() {
            queue.add(future);
          }
        },
        directExecutor());
    return future;
  }

  /**

protected java.util.List fListeners; protected int fRunTests; private boolean fStop; public void TestResult(); public synchronized void addError(Test, Throwable); public synchronized void addFailure(Test, AssertionFailedError); public synchronized void addListener(TestListener); public synchronized void removeListener(TestListener); private synchronized java.util.List cloneListeners(); public void endTest(Test); public synchronized int errorCount(); public synchronized java.util.Enumeration errors(); public...

getRemoteRepostories(); public ArtifactResolutionRe setRemoteRepostories(java.util.List); public filter.ArtifactFilter getFilter(); public ArtifactResolutionRe setFilter(filter.ArtifactFilter); public java.util.List getListeners(); public ArtifactResolutionRe addListener(ResolutionListener); public org.apache.maven.artifact.metadata.ArtifactMetadataSour getMetadataSource(); public ArtifactResolutionRe setMetadataSource(org.apache.maven.artifact.metadata.ArtifactMetadataSour); public java.util.Map getManagedVersionMap();...

getRemoteRepostories(); public ArtifactResolutionRe setRemoteRepostories(java.util.List); public filter.ArtifactFilter getFilter(); public ArtifactResolutionRe setFilter(filter.ArtifactFilter); public java.util.List getListeners(); public ArtifactResolutionRe addListener(ResolutionListener); public org.apache.maven.artifact.metadata.ArtifactMetadataSour getMetadataSource(); public ArtifactResolutionRe setMetadataSource(org.apache.maven.artifact.metadata.ArtifactMetadataSour); public java.util.Map getManagedVersionMap();...

        final LoadingValueReference<K, V> loadingValueReference,
        CacheLoader<? super K, V> loader) {
      final ListenableFuture<V> loadingFuture = loadingValueReference.loadFuture(key, loader);
      loadingFuture.addListener(
          () -> {
            try {
              getAndRecordStats(key, hash, loadingValueReference, loadingFuture);
            } catch (Throwable t) {

        final LoadingValueReference<K, V> loadingValueReference,
        CacheLoader<? super K, V> loader) {
      final ListenableFuture<V> loadingFuture = loadingValueReference.loadFuture(key, loader);
      loadingFuture.addListener(
          () -> {
            try {
              getAndRecordStats(key, hash, loadingValueReference, loadingFuture);
            } catch (Throwable t) {