Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 86 for listenablefuture (0.07 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

     *
     * @author Sven Mawson
     */
    @NullUnmarked
    public class ListenableFutureTester {
    
      private final ExecutorService exec;
      private final ListenableFuture<?> future;
      private final CountDownLatch latch;
    
      public ListenableFutureTester(ListenableFuture<?> future) {
        this.exec = newCachedThreadPool();
        this.future = checkNotNull(future);
        this.latch = new CountDownLatch(1);
      }
    
      public void setUp() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.ArrayDeque;
    import java.util.Deque;
    import java.util.Map;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  3. futures/failureaccess/pom.xml

        classes are conceptually a part of Guava, but they're in this separate
        artifact so that Android libraries can use them without pulling in all of
        Guava (just as they can use ListenableFuture by depending on the
        listenablefuture artifact).
      </description>
      <build>
        <plugins>
          <plugin>
            <artifactId>maven-compiler-plugin</artifactId>
            <executions>
              <execution>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 18:13:11 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/CollectionFuture.java

       */
      @LazyInit private @Nullable List<@Nullable Present<V>> values;
    
      @SuppressWarnings("EmptyList") // ImmutableList doesn't support nullable element types
      CollectionFuture(
          ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
          boolean allMustSucceed) {
        super(futures, allMustSucceed, true);
    
        List<@Nullable Present<V>> values =
            futures.isEmpty()
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ExecutionList.java

       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
       * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener}
       * documentation.
       */
      public void add(Runnable runnable, Executor executor) {
        // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function,
     * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly
     * different signatures.
     */
    @GwtCompatible
    @J2ktIncompatible // Super-sourced
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      }
    
      public void testSetFuture_misbehavingFutureThrows() throws Exception {
        SettableFuture<String> future = SettableFuture.create();
        ListenableFuture<String> badFuture =
            new ListenableFuture<String>() {
              @Override
              public boolean cancel(boolean interrupt) {
                return false;
              }
    
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/package-info.java

     * the License.
     */
    
    /**
     * Concurrency utilities.
     *
     * <p>Commonly used types include {@link ClosingFuture}, {@link ListenableFuture}, and {@link
     * Service}.
     *
     * <p>Commonly used utilities include {@link Futures}, {@link MoreExecutors}, {@link
     * ThreadFactoryBuilder}, and {@link Uninterruptibles}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 14:50:24 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

    import com.google.common.annotations.J2ktIncompatible;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
     * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function,
     * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly
     * different signatures.
     */
    @GwtCompatible
    @J2ktIncompatible // Super-sourced
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/FutureCallback.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A callback for accepting the results of a {@link java.util.concurrent.Future} computation
     * asynchronously.
     *
     * <p>To attach to a {@link ListenableFuture} use {@link Futures#addCallback}.
     *
     * @author Anthony Zana
     * @since 10.0
     */
    @GwtCompatible
    public interface FutureCallback<V extends @Nullable Object> {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
Back to top