Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for isDone (0.13 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/GcFinalization.java

      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  if (!future.isDone()) {
                    errorMessage.set("Set call exited before future was complete.");
                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.setException(new IllegalArgumentException("failure"));
                  if (!future.isDone()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                      assertTrue(future.isDone());
                      assertEquals(1, threadLocalCount.get().intValue());
                    } catch (Throwable t) {
                      throwableFromOtherThread.set(t);
                    }
                  }
                });
    
        otherThread.start();
    
        ListenableFuture<?> future = executor.submit(incrementTask);
        assertTrue(future.isDone());
        assertListenerRunImmediately(future);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top