Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SettableFuture (0.21 sec)

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

              }
            };
    
        final SettableFuture<String> delayedSuccess = SettableFuture.create();
        final SettableFuture<String> delayedFailed = SettableFuture.create();
        final SettableFuture<String> delayedCancelled = SettableFuture.create();
    
        final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create();
        final ListenableFuture<String> delayedRuntimeException =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

              }
            };
    
        final SettableFuture<String> delayedSuccess = SettableFuture.create();
        final SettableFuture<String> delayedFailed = SettableFuture.create();
        final SettableFuture<String> delayedCancelled = SettableFuture.create();
    
        final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create();
        final ListenableFuture<String> delayedRuntimeException =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  3. 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());
        }
    
        /*
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 144.7K bytes
    - Viewed (0)
  4. 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 =
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 112.3K bytes
    - Viewed (0)
  5. 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 =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 110.7K bytes
    - Viewed (0)
  6. 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(null);
        }
    
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
Back to top