Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 105 for isDone (0.26 sec)

  1. android/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
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  2. android/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 {
        try {
          future.setFuture(null);
          fail();
        } catch (NullPointerException expected) {
        }
    
        assertThat(future.isDone()).isFalse();
        assertThat(future.set(1)).isTrue();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                isInterruptibleRegistered.countDown();
                new CountDownLatch(1).await(); // the interrupt will wake us up
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
                return "";
              }
    
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  4. 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);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (3)
  5. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                isInterruptibleRegistered.countDown();
                new CountDownLatch(1).await(); // the interrupt will wake us up
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
                return "";
              }
    
              @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/CombinedFuture.java

        CombinedFutureInterruptibleTask(Executor listenerExecutor) {
          this.listenerExecutor = checkNotNull(listenerExecutor);
        }
    
        @Override
        final boolean isDone() {
          return CombinedFuture.this.isDone();
        }
    
        final void execute() {
          try {
            listenerExecutor.execute(this);
          } catch (RejectedExecutionException e) {
            CombinedFuture.this.setException(e);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

       * TimeUnit)} overload in order to test that method.
       */
      static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException {
        checkState(future.isDone(), "Future was expected to be done: %s", future);
        try {
          return getUninterruptibly(future, 0, SECONDS);
        } catch (TimeoutException e) {
          AssertionFailedError error = new AssertionFailedError(e.getMessage());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 2.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/DirFileEntryEnumIterator2.java

                }
                throw e;
            }
            return true;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.smb.DirFileEntryEnumIteratorBase#isDone()
         */
        @Override
        protected boolean isDone () {
            return false;
        }
    
    
        /**
         * @throws CIFSException
         */
        @Override
        protected void doCloseInternal () throws CIFSException {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Dec 20 16:15:08 GMT 2020
    - 5.7K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/FileBackedOutputStreamAndroidIncompatibleTest.java

        out = null;
    
        // times out and throws RuntimeException on failure
        GcFinalization.awaitDone(
            new GcFinalization.FinalizationPredicate() {
              @Override
              public boolean isDone() {
                return !file.exists();
              }
            });
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jun 08 21:20:23 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AsyncCallable.java

     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public interface AsyncCallable<V extends @Nullable Object> {
      /**
       * Computes a result {@code Future}. The output {@code Future} need not be {@linkplain
       * Future#isDone done}, making {@code AsyncCallable} suitable for asynchronous derivations.
       *
       * <p>Throwing an exception from this method is equivalent to returning a failing {@link
       * ListenableFuture}.
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Dec 14 15:53:12 GMT 2021
    - 1.5K bytes
    - Viewed (0)
Back to top