Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for cancel (0.15 sec)

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

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    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

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    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/util/concurrent/ClosingFuture.java

        consumer.accept(new ValueAndCloser<C>(closingFuture));
      }
    
      /**
       * Attempts to cancel execution of this step. This attempt will fail if the step has already
       * completed, has already been cancelled, or could not be cancelled for some other reason. If
       * successful, and this step has not started when {@code cancel} is called, this step should never
       * run.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/LocalCache.java

            set(newValue);
          } else {
            // The pending load was removed. Delay notifications until loading completes.
            oldValue = unset();
          }
    
          // TODO(fry): could also cancel loading if we had a handle on its future
        }
    
        public ListenableFuture<V> loadFuture(K key, CacheLoader<? super K, V> loader) {
          try {
            stopwatch.start();
    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)
  5. android/guava/src/com/google/common/cache/LocalCache.java

            set(newValue);
          } else {
            // The pending load was removed. Delay notifications until loading completes.
            oldValue = unset();
          }
    
          // TODO(fry): could also cancel loading if we had a handle on its future
        }
    
        public ListenableFuture<V> loadFuture(K key, CacheLoader<? super K, V> loader) {
          try {
            stopwatch.start();
    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)
Back to top