Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 66 for addListener (0.09 seconds)

  1. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       *
       * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
       * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
       * internal, unbounded pool at the first call to {@code addListener} and holding it until the
       * future is {@linkplain Future#isDone() done}.
       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  2. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * </ul>
     *
     * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will
     * rarely use it directly, in part because it does not provide direct access to the {@code Future}
     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * {@snippet :
     * final String name = ...;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        listenable.addListener(earlyListener, directExecutor());
    
        input.allowGetToComplete.countDown();
        // Now give the get() thread time to finish:
        assertTrue(earlyListener.wasRun.await(1, SECONDS));
    
        // Now test an additional addListener call, which will be run in-thread:
        RecordingRunnable lateListener = new RecordingRunnable();
        listenable.addListener(lateListener, directExecutor());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          // racing addListener calls and addListener calls completing after the future completes.
          Runnable listener = k % 2 == 0 ? collectResultsRunnable : collectResultsTimedGetRunnable;
          allTasks.add(callable(listener));
          allTasks.add(
              () -> {
                currentFuture.get().addListener(listener, executor);
                return null;
              });
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * </ul>
     *
     * <p>The main purpose of {@link #addListener addListener} is to support this chaining. You will
     * rarely use it directly, in part because it does not provide direct access to the {@code Future}
     * result. (If you want such access, you may prefer {@link Futures#addCallback
     * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful:
     *
     * {@snippet :
     * final String name = ...;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          // racing addListener calls and addListener calls completing after the future completes.
          Runnable listener = k % 2 == 0 ? collectResultsRunnable : collectResultsTimedGetRunnable;
          allTasks.add(callable(listener));
          allTasks.add(
              () -> {
                currentFuture.get().addListener(listener, executor);
                return null;
              });
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java

      protected ForwardingListenableFuture() {}
    
      @Override
      protected abstract ListenableFuture<? extends V> delegate();
    
      @Override
      public void addListener(Runnable listener, Executor exec) {
        delegate().addListener(listener, exec);
      }
    
      // TODO(cpovirk): Use standard Javadoc form for SimpleForwarding* class and constructor
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 3K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        listenable.addListener(earlyListener, directExecutor());
    
        input.allowGetToComplete.countDown();
        // Now give the get() thread time to finish:
        assertTrue(earlyListener.wasRun.await(1, SECONDS));
    
        // Now test an additional addListener call, which will be run in-thread:
        RecordingRunnable lateListener = new RecordingRunnable();
        listenable.addListener(lateListener, directExecutor());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

     * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
     * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}.
     *
     * <p>Few users should use this class. It is intended primarily for those who are implementing an
     * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
Back to Top