Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 105 for isDone (0.18 sec)

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

        checkNotNull(unit);
        return get();
      }
    
      @Override
      public boolean isCancelled() {
        return false;
      }
    
      @Override
      public boolean isDone() {
        return true;
      }
    
      @Override
      public String toString() {
        // Behaviour analogous to AbstractFuture#toString().
        return super.toString() + "[status=SUCCESS, result=[" + value + "]]";
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        final MockReference reference = new MockReference(frq = new FinalizableReferenceQueue());
    
        GcFinalization.awaitDone(
            new GcFinalization.FinalizationPredicate() {
              @Override
              public boolean isDone() {
                return reference.finalizeReferentCalled;
              }
            });
      }
    
      static class MockReference extends FinalizableWeakReference<Object> {
    
        volatile boolean finalizeReferentCalled;
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Oct 10 08:40:05 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

        final MockReference reference = new MockReference(frq = new FinalizableReferenceQueue());
    
        GcFinalization.awaitDone(
            new GcFinalization.FinalizationPredicate() {
              public boolean isDone() {
                return reference.finalizeReferentCalled;
              }
            });
      }
    
      static class MockReference extends FinalizableWeakReference<Object> {
    
        volatile boolean finalizeReferentCalled;
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Oct 10 08:40:05 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

    /**
     * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
     * complete}. If the computation has already completed when the listener is added, the listener will
     * execute immediately.
     *
     * <p>See the Guava User Guide article on <a
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

            throws InterruptedException, ExecutionException, TimeoutException {
          return super.get(timeout, unit);
        }
    
        @Override
        public final boolean isDone() {
          return super.isDone();
        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 11 19:08:44 GMT 2023
    - 18.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

           * important for other reasons: run() can still be invoked concurrently in different threads,
           * even with the above null checks.)
           */
          timeoutFutureRef = null;
          if (delegate.isDone()) {
            timeoutFuture.setFuture(delegate);
          } else {
            try {
              ScheduledFuture<?> timer = timeoutFuture.timer;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     * previous callable has returned -- and, if the previous callable was an {@link AsyncCallable}, not
     * until the {@code Future} it returned is {@linkplain Future#isDone done} (successful, failed, or
     * cancelled).
     *
     * <p>This class serializes execution of <i>submitted</i> tasks but not any <i>listeners</i> of
     * those tasks.
     *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      }
                    }),
                executor);
        ListenableFuture<?> statusFuture = closingFuture.statusFuture();
        waiter.awaitStarted();
        assertThat(statusFuture.isDone()).isFalse();
        waiter.awaitReturned();
        assertThat(getUninterruptibly(statusFuture)).isNull();
      }
    
      public void testStatusFuture_failure() throws Exception {
        ClosingFuture<String> closingFuture =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      }
                    }),
                executor);
        ListenableFuture<?> statusFuture = closingFuture.statusFuture();
        waiter.awaitStarted();
        assertThat(statusFuture.isDone()).isFalse();
        waiter.awaitReturned();
        assertThat(getUninterruptibly(statusFuture)).isNull();
      }
    
      public void testStatusFuture_failure() throws Exception {
        ClosingFuture<String> closingFuture =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

            }
          };
    
      public void testServiceStartStop() throws Exception {
        NullService service = new NullService();
        service.startAsync().awaitRunning();
        assertFalse(future.isDone());
        service.stopAsync().awaitTerminated();
        assertTrue(future.isCancelled());
      }
    
      private class NullService extends AbstractScheduledService {
        @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
Back to top