- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for afterRanInterruptiblyFailure (0.25 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java
afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result)); } else { afterRanInterruptiblyFailure(error); } } abstract boolean isDone(); abstract T runInterruptibly() throws Exception; abstract void afterRanInterruptiblySuccess(T result); abstract void afterRanInterruptiblyFailure(Throwable error); final void interruptTask() {} abstract String toPendingString();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 08 20:30:27 GMT 2022 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @Override void afterRanInterruptiblySuccess(@ParametricNullness V result) { TrustedListenableFutureTask.this.set(result); } @Override void afterRanInterruptiblyFailure(Throwable error) { setException(error); } @Override String toPendingString() { return callable.toString(); } } @WeakOuter
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
String toPendingString() { return ""; } @Override void afterRanInterruptiblySuccess(@Nullable Void result) {} @Override void afterRanInterruptiblyFailure(Throwable error) {} }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await();
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) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
String toPendingString() { return ""; } @Override void afterRanInterruptiblySuccess(@Nullable Void result) {} @Override void afterRanInterruptiblyFailure(Throwable error) {} }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await();
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) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
if (error == null) { // The cast is safe because of the `run` and `error` checks. afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result)); } else { afterRanInterruptiblyFailure(error); } } } } private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
* pendingToString().) */ CombinedFuture.this.task = null; setValue(result); } @Override final void afterRanInterruptiblyFailure(Throwable error) { // See afterRanInterruptiblySuccess. CombinedFuture.this.task = null; if (error instanceof ExecutionException) { /*
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)