- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for afterRanInterruptiblyFailure (0.18 seconds)
-
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();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.6K bytes - Click Count (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(); } } @WeakOuterCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
} @Override void afterRanInterruptiblySuccess(String result) { taskResult.set(result); } @Override void afterRanInterruptiblyFailure(Throwable error) { taskResult.setException(error); } }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
} @Override void afterRanInterruptiblySuccess(String result) { taskResult.set(result); } @Override void afterRanInterruptiblyFailure(Throwable error) { taskResult.setException(error); } }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (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); } } } } @SuppressWarnings({ "Interruption", // We are restoring an interrupt on this thread. "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (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) { /*
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.8K bytes - Click Count (0)