Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 36 of 36 for SettableFuture (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

         * have completed - namely after oldFuture is done, and taskFuture has either completed or been
         * cancelled before the callable started execution.
         */
        SettableFuture<@Nullable Void> newFuture = SettableFuture.create();
    
        ListenableFuture<@Nullable Void> oldFuture = ref.getAndSet(newFuture);
    
        // Invoke our task once the previous future completes.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

         * have completed - namely after oldFuture is done, and taskFuture has either completed or been
         * cancelled before the callable started execution.
         */
        SettableFuture<@Nullable Void> newFuture = SettableFuture.create();
    
        ListenableFuture<@Nullable Void> oldFuture = ref.getAndSet(newFuture);
    
        // Invoke our task once the previous future completes.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. 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 =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K 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 =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/FluentFuture.java

     * forwards to that future and adds the desired methods.
     *
     * @since 23.0
     */
    @DoNotMock("Use FluentFuture.from(Futures.immediate*Future) or SettableFuture")
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    public abstract class FluentFuture<V extends @Nullable Object>
        extends GwtFluentFutureCatchingSpecialization<V> {
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K 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);
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
Back to top