- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for cancel (0.17 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Note: The only way this CAS could fail is if cancel() has raced with us. That is ok. boolean unused = ATOMIC_HELPER.casValue(this, valueToSet, failure); } return true; } localValue = value; // we lost the cas, fall through and maybe cancel } // The future has already been set to something. If it is cancellation we should cancel the // incoming future.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
this.state = state; } @Override public boolean cancel(boolean interruptIfRunning) { InCompletionOrderState<T> localState = state; if (super.cancel(interruptIfRunning)) { /* * requireNonNull is generally safe: If cancel succeeded, then this Future was still * pending, so its `state` field hasn't been nulled out yet. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitStarted(); // Everything should still be open. assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4. assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue(); step2Waiter.awaitReturned(); step4Waiter.awaitStarted(); // Step 1 is not cancelled because it was done.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitStarted(); // Everything should still be open. assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4. assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue(); step2Waiter.awaitReturned(); step4Waiter.awaitStarted(); // Step 1 is not cancelled because it was done.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
public void run() { thirdSignal.countDown(); result.set(1, cache.getUnchecked(key)); doneSignal.countDown(); } }.start(); // give the second get a chance to run; it is okay for this to be racy // as the end result should be the same either way thirdSignal.await(); Thread.yield(); // Expand! CacheTesting.forceExpandSegment(cache, key);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
public void run() { thirdSignal.countDown(); result.set(1, cache.getUnchecked(key)); doneSignal.countDown(); } }.start(); // give the second get a chance to run; it is okay for this to be racy // as the end result should be the same either way thirdSignal.await(); Thread.yield(); // Expand! CacheTesting.forceExpandSegment(cache, key);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0)