Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 52 for SettableFuture (0.09 seconds)

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

    import org.jspecify.annotations.Nullable;
    
    /**
     * An abstract implementation of {@link ListenableFuture}, intended for advanced users only. More
     * common ways to create a {@code ListenableFuture} include instantiating a {@link SettableFuture},
     * submitting a task to a {@link ListeningExecutorService}, and deriving a {@code Future} from an
     * existing one, typically using methods like {@link Futures#transform(ListenableFuture,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

        assertThrows(CancellationException.class, () -> getDone(immediateCancelledFuture()));
      }
    
      public void testPending() throws ExecutionException {
        assertThrows(IllegalStateException.class, () -> getDone(SettableFuture.create()));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  3. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java

       *       return value of this method as its cause
       * </ul>
       *
       * <p>This method is {@code protected} so that classes like {@code
       * com.google.common.util.concurrent.SettableFuture} do not expose it to their users as an
       * instance method. In the unlikely event that you need to call this method, call {@link
       * InternalFutures#tryInternalFastPathGetFailure(InternalFutureFailureAccess)}.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 18 02:54:30 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

        assertThrows(CancellationException.class, () -> getDone(immediateCancelledFuture()));
      }
    
      public void testPending() throws ExecutionException {
        assertThrows(IllegalStateException.class, () -> getDone(SettableFuture.create()));
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        assertThat(helperField.get(null).getClass().getSimpleName()).isEqualTo(expectedHelperClassName);
      }
    
      private static ClassLoader getClassLoader(Set<String> blocklist) {
        String concurrentPackage = SettableFuture.class.getPackage().getName();
        ClassLoader classLoader = AggregateFutureStateFallbackAtomicHelperTest.class.getClassLoader();
        // we delegate to the current classloader so both loaders agree on classes like TestCase
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/cache/LocalCache.java

        volatile ValueReference<K, V> oldValue;
    
        // TODO(fry): rename get, then extend AbstractFuture instead of containing SettableFuture
        final SettableFuture<V> futureValue = SettableFuture.create();
        final Stopwatch stopwatch = Stopwatch.createUnstarted();
    
        public LoadingValueReference() {
          this(LocalCache.<K, V>unset());
        }
    
        /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

      }
    
      public void testLongAsyncRefresh() throws Exception {
        FakeTicker ticker = new FakeTicker();
        CountDownLatch reloadStarted = new CountDownLatch(1);
        SettableFuture<Thread> threadAboutToBlockForRefresh = SettableFuture.create();
    
        ListeningExecutorService refreshExecutor = listeningDecorator(newSingleThreadExecutor());
        try {
          CacheBuilder<Object, Object> builder =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/cache/LocalCacheTest.java

      }
    
      public void testLongAsyncRefresh() throws Exception {
        FakeTicker ticker = new FakeTicker();
        CountDownLatch reloadStarted = new CountDownLatch(1);
        SettableFuture<Thread> threadAboutToBlockForRefresh = SettableFuture.create();
    
        ListeningExecutorService refreshExecutor = listeningDecorator(newSingleThreadExecutor());
        try {
          CacheBuilder<Object, Object> builder =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        assertThat(helperField.get(null).getClass().getSimpleName()).isEqualTo(expectedHelperClassName);
      }
    
      private static ClassLoader getClassLoader(Set<String> blocklist) {
        String concurrentPackage = SettableFuture.class.getPackage().getName();
        ClassLoader classLoader = AggregateFutureStateFallbackAtomicHelperTest.class.getClassLoader();
        // we delegate to the current classloader so both loaders agree on classes like TestCase
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

        assertThat(helperMethod.invoke(null)).isEqualTo(expectedHelperClassName);
      }
    
      private static ClassLoader getClassLoader(Set<String> disallowedClassNames) {
        String concurrentPackage = SettableFuture.class.getPackage().getName();
        ClassLoader classLoader = AbstractFutureFallbackAtomicHelperTest.class.getClassLoader();
        // we delegate to the current classloader so both loaders agree on classes like TestCase
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.3K bytes
    - Click Count (0)
Back to Top