Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for addListener (0.11 sec)

  1. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

                  } catch (Throwable expected) {
                  }
                }
              };
          thread.start();
          blockedThreads.add(thread);
        }
        for (int i = 0; i < numListeners; i++) {
          f.addListener(Runnables.doNothing(), directExecutor());
        }
        for (Thread thread : blockedThreads) {
          AbstractFutureBenchmarks.awaitWaiting(thread);
        }
        switch (state) {
          case NOT_DONE:
            break;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener1, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener1, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener1, 1));
        queue.enqueue(incrementingEvent(counters, listener1, 2));
    
        Object listener2 = new Object();
        queue.addListener(listener2, directExecutor());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  4. 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:
     *
     * <pre>{@code
     * final String name = ...;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  5. 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:
     *
     * <pre>{@code
     * final String name = ...;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  7. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      private final ListenableFuture<V> delegate;
    
      ForwardingFluentFuture(ListenableFuture<V> delegate) {
        this.delegate = checkNotNull(delegate);
      }
    
      @Override
      public void addListener(Runnable listener, Executor executor) {
        delegate.addListener(listener, executor);
      }
    
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. 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:
     *
     * <pre>{@code
     * final String name = ...;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        delegate.addListener(fire, directExecutor());
        return result;
      }
    
      /*
       * Memory visibility of these fields. There are two cases to consider.
       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top