Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 332 for Executor (0.05 seconds)

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

       */
      public static <V extends @Nullable Object> ListenableFuture<V> listenInPoolThread(
          Future<V> future, Executor executor) {
        checkNotNull(executor);
        if (future instanceof ListenableFuture) {
          return (ListenableFuture<V>) future;
        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
    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. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

      }
    
      /**
       * Adds a listener that will be called using the given executor when events are later {@link
       * #enqueue enqueued} and {@link #dispatch dispatched}.
       */
      public void addListener(L listener, Executor executor) {
        checkNotNull(listener, "listener");
        checkNotNull(executor, "executor");
        listeners.add(new PerListenerQueue<>(listener, executor));
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  3. guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          final Runnable runnable;
          final Executor executor;
    
          RunnableExecutorPair(Runnable runnable, Executor executor) {
            this.runnable = runnable;
            this.executor = executor;
          }
    
          void execute() {
            try {
              executor.execute(runnable);
            } catch (RuntimeException e) {
              log.log(
                  Level.SEVERE,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/cache/RemovalListeners.java

       */
      public static <K, V> RemovalListener<K, V> asynchronous(
          RemovalListener<K, V> listener, Executor executor) {
        checkNotNull(listener);
        checkNotNull(executor);
        return (RemovalNotification<K, V> notification) ->
            executor.execute(() -> listener.onRemoval(notification));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  5. guava/src/com/google/common/cache/RemovalListeners.java

       */
      public static <K, V> RemovalListener<K, V> asynchronous(
          RemovalListener<K, V> listener, Executor executor) {
        checkNotNull(listener);
        checkNotNull(executor);
        return (RemovalNotification<K, V> notification) ->
            executor.execute(() -> listener.onRemoval(notification));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  6. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java

          Function<? super Throwable, ? extends V> fallback,
          Executor executor) {
        return (FluentFuture<V>) Futures.catching(this, exceptionType, fallback, executor);
      }
    
      public final FluentFuture<V> catchingAsync(
          Class<Throwable> exceptionType,
          AsyncFunction<? super Throwable, ? extends V> fallback,
          Executor executor) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/eventbus/AsyncEventBus.java

       *
       * @param identifier short name for the bus, for logging purposes.
       * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
       *     down the executor after the last event has been posted to this event bus.
       */
      public AsyncEventBus(String identifier, Executor executor) {
        super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  8. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

          Executor executor) {
        return AbstractCatchingFuture.create(input, exceptionType, fallback, executor);
      }
    
      public static <V extends @Nullable Object> ListenableFuture<V> catchingAsync(
          ListenableFuture<? extends V> input,
          Class<Throwable> exceptionType,
          AsyncFunction<? super Throwable, ? extends V> fallback,
          Executor executor) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

        executor.execute(task);
        return task;
      }
    
      /**
       * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that
       * will complete after execution.
       *
       * @throws RejectedExecutionException if the task cannot be scheduled for execution
       * @since 28.2
       */
      public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

       *
       * @param listener the listener to run when the computation is complete
       * @param executor the executor to run the listener in
       * @throws RejectedExecutionException if we tried to execute the listener immediately but the
       *     executor rejected it.
       */
      void addListener(Runnable listener, Executor executor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
Back to Top