- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 80 for isDone (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)