- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for setException (0.09 sec)
-
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
} public void testSetFailure() throws Exception { assertTrue(future.setException(new Exception("failure"))); tester.testFailedFuture("failure"); } public void testSetFailureNull() throws Exception { assertThrows(NullPointerException.class, () -> future.setException(null)); assertFalse(future.isDone()); assertTrue(future.setException(new Exception("failure"))); tester.testFailedFuture("failure"); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SettableFuture.java
@CanIgnoreReturnValue @Override public boolean set(@ParametricNullness V value) { return super.set(value); } @CanIgnoreReturnValue @Override public boolean setException(Throwable throwable) { return super.setException(throwable); } @CanIgnoreReturnValue @Override public boolean setFuture(ListenableFuture<? extends V> future) { return super.setFuture(future); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
@CanIgnoreReturnValue @Override public boolean set(@ParametricNullness V value) { return super.set(value); } @CanIgnoreReturnValue @Override public boolean setException(Throwable throwable) { return super.setException(throwable); } @CanIgnoreReturnValue @Override public boolean setFuture(ListenableFuture<? extends V> future) { return super.setFuture(future); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* thread immediately fails with the same exception: * * Thread1: calls setException(), which returns true, context switch before it can CAS * seenExceptionsField to its exception * * Thread2: calls setException(), which returns false, CASes seenExceptionsField to its * exception, and wrongly believes that its exception is new (leading it to logging it when it
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
return new UncheckedThrowingFuture<V>(); } public void complete(RuntimeException e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } } public void complete(Error e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
void afterRanInterruptiblySuccess(@ParametricNullness V result) { TrustedListenableFutureTask.this.set(result); } @Override void afterRanInterruptiblyFailure(Throwable error) { setException(error); } @Override String toPendingString() { return callable.toString(); } } @WeakOuter private final class TrustedFutureInterruptibleAsyncTask
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* class with a manual reference back to the "containing" class.) * * This has the nice-ish side effect of limiting reentrancy: run() calls * timeoutFuture.setException() calls run(). That reentrancy would already be harmless, since * timeoutFuture can be set (and delegate cancelled) only once. (And "set only once" is
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ImmediateFuture.java
} static final class ImmediateFailedFuture<V extends @Nullable Object> extends TrustedFuture<V> { ImmediateFailedFuture(Throwable thrown) { setException(thrown); } } static final class ImmediateCancelledFuture<V extends @Nullable Object> extends TrustedFuture<V> { static final @Nullable ImmediateCancelledFuture<Object> INSTANCE =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
SettableFuture<String> f = SettableFuture.create(); Exception e = new IllegalArgumentException("foo not found"); MockCallback callback = new MockCallback(e); addCallback(f, callback, directExecutor()); f.setException(e); } public void testCancel() { SettableFuture<String> f = SettableFuture.create(); FutureCallback<String> callback = new FutureCallback<String>() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 6.7K bytes - Viewed (0)