Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 59 for addListener (0.08 sec)

  1. guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      ImmediateFuture(@ParametricNullness V value) {
        this.value = value;
      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void addListener(Runnable listener, Executor executor) {
        checkNotNull(listener, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
        try {
          executor.execute(listener);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

              final AbstractFuture<?> future = new AbstractFuture<Object>() {};
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                future.addListener(runnable, executor);
              }
    
              @Override
              public void execute() {
                future.set(null);
              }
    
              @SuppressWarnings("FutureReturnValueIgnored")
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              }
    
              @Override
              public String get(long time, TimeUnit unit) {
                return "foo"; // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        Future<?> future = newFutureInstance();
        future
            .getClass()
            .getMethod(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

              }
    
              @Override
              public String get(long time, TimeUnit unit) {
                return "foo"; // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        Future<?> future = newFutureInstance();
        future
            .getClass()
            .getMethod(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/Service.java

       * service changes state. The listener will not have previous state changes replayed, so it is
       * suggested that listeners are added before the service starts.
       *
       * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          ListenableFuture<I> input,
          AsyncFunction<? super I, ? extends O> function,
          Executor executor) {
        AsyncTransformFuture<I, O> output = new AsyncTransformFuture<>(input, function);
        input.addListener(output, rejectionPropagatingExecutor(executor, output));
        return output;
      }
    
      static <I extends @Nullable Object, O extends @Nullable Object> ListenableFuture<O> create(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

                return null;
            }
    
            @Override
            public void addListener(String className) {
            }
    
            @Override
            public <T extends java.util.EventListener> void addListener(T t) {
            }
    
            @Override
            public void addListener(Class<? extends java.util.EventListener> listenerClass) {
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractService.java

      @Override
      public final Throwable failureCause() {
        return snapshot.failureCause();
      }
    
      /**
       * @since 13.0
       */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

                  }
                  return 25;
                }
              });
    
      @Override
      protected void setUp() throws Exception {
        super.setUp();
    
        exec = newCachedThreadPool();
    
        task.addListener(
            new Runnable() {
              @Override
              public void run() {
                listenerLatch.countDown();
              }
            },
            directExecutor());
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

        // taskFuture guarantees completion if the callable is invoked, and adding to outputFuture
        // propagates cancellation if the callable has not yet been invoked.
        outputFuture.addListener(listener, directExecutor());
        taskFuture.addListener(listener, directExecutor());
    
        return outputFuture;
      }
    
      enum RunningState {
        NOT_RUN,
        CANCELLED,
        STARTED,
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top