Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 80 for isDone (0.05 sec)

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

      // Why 1000?  WHY NOT!
      private static final int MAX_BUSY_WAIT_SPINS = 1000;
    
      @Override
      public final void run() {
        /*
         * Set runner thread before checking isDone(). If we were to check isDone() first, the task
         * might be cancelled before we set the runner thread. That would make it impossible to
         * interrupt, yet it will still run, since interruptTask will leave the runner value null,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      // Why 1000?  WHY NOT!
      private static final int MAX_BUSY_WAIT_SPINS = 1000;
    
      @Override
      public final void run() {
        /*
         * Set runner thread before checking isDone(). If we were to check isDone() first, the task
         * might be cancelled before we set the runner thread. That would make it impossible to
         * interrupt, yet it will still run, since interruptTask will leave the runner value null,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertThat(future.isDone()).isFalse();
        assertThat(future.set(1)).isTrue();
        assertSuccessful(future, 1);
      }
    
      public void testSetFutureNull() throws Exception {
        assertThrows(NullPointerException.class, () -> future.setFuture(null));
    
        assertThat(future.isDone()).isFalse();
        assertThat(future.set(1)).isTrue();
        assertSuccessful(future, 1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/hash/Murmur3_32HashFunction.java

        private int h1;
        private long buffer;
        private int shift;
        private int length;
        private boolean isDone;
    
        Murmur3_32Hasher(int seed) {
          this.h1 = seed;
          this.length = 0;
          isDone = false;
        }
    
        private void update(int nBytes, long update) {
          // 1 <= nBytes <= 4
          buffer |= (update & 0xFFFFFFFFL) << shift;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
       * internal, unbounded pool at the first call to {@code addListener} and holding it until the
       * future is {@linkplain Future#isDone() done}.
       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
       * MoreExecutors#listeningDecorator( java.util.concurrent.ExecutorService)}, {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         */
        @CanIgnoreReturnValue
        @Override
        public V get() throws InterruptedException, ExecutionException {
          return sync.get();
        }
    
        @Override
        public boolean isDone() {
          return sync.isDone();
        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top