Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 80 for isDone (0.07 sec)

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

          // at the beginning of the loop.
          int i = 0;
          for (ListenableFuture<? extends InputT> future : futures) {
            int index = i++;
            if (future.isDone()) {
              processAllMustSucceedDoneFuture(index, future);
            } else {
              future.addListener(
                  () -> processAllMustSucceedDoneFuture(index, future), directExecutor());
            }
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. 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.
     *
    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/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 {
              @RetainedLocalRef ScheduledFuture<?> timer = timeoutFuture.timer;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. 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.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        }
      }
    
      public interface TrackedRunnable extends Runnable {
        boolean isDone();
      }
    
      public static TrackedRunnable trackedRunnable(final long timeoutMillis) {
        return new TrackedRunnable() {
          private volatile boolean done = false;
    
          @Override
          public boolean isDone() {
            return done;
          }
    
          @Override
          public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        }
      }
    
      public interface TrackedRunnable extends Runnable {
        boolean isDone();
      }
    
      public static TrackedRunnable trackedRunnable(final long timeoutMillis) {
        return new TrackedRunnable() {
          private volatile boolean done = false;
    
          @Override
          public boolean isDone() {
            return done;
          }
    
          @Override
          public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        @SuppressWarnings("unchecked")
        LoadingValueReference<Object, Object> valueReference =
            (LoadingValueReference) newEntry.getValueReference();
        assertFalse(valueReference.futureValue.isDone());
        startSignal.countDown();
    
        try {
          doneSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.cleanUp(); // force notifications
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        @SuppressWarnings("unchecked")
        LoadingValueReference<Object, Object> valueReference =
            (LoadingValueReference) newEntry.getValueReference();
        assertFalse(valueReference.futureValue.isDone());
        startSignal.countDown();
    
        try {
          doneSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.cleanUp(); // force notifications
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/LocalCache.java

          if (loadingValueReference == null) {
            return null;
          }
    
          ListenableFuture<V> result = loadAsync(key, hash, loadingValueReference, loader);
          if (result.isDone()) {
            try {
              return Uninterruptibles.getUninterruptibly(result);
            } catch (Throwable t) {
              // don't let refresh exceptions propagate; error was already logged
            }
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/core/lang/StringUtilTest.java

        @Test
        public void testStartsWithIgnoreCase() throws Exception {
            assertTrue(StringUtil.startsWithIgnoreCase("isHoge", "is"));
            assertTrue(StringUtil.startsWithIgnoreCase("isHoge", "IS"));
            assertTrue(StringUtil.startsWithIgnoreCase("ISHoge", "is"));
            assertFalse(StringUtil.startsWithIgnoreCase("isHoge", "iss"));
            assertFalse(StringUtil.startsWithIgnoreCase("is", "iss"));
        }
    
        /**
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top