- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for interruptTask (0.14 seconds)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java
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/CombinedFuture.java
*/ if (reason == OUTPUT_FUTURE_DONE) { this.task = null; } } @Override protected void interruptTask() { @RetainedLocalRef CombinedFutureInterruptibleTask<?> localTask = task; if (localTask != null) { localTask.interruptTask(); } } @WeakOuter private abstract class CombinedFutureInterruptibleTask<T extends @Nullable Object>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) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
} }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await(); RuntimeException expected = assertThrows(RuntimeException.class, task::interruptTask); assertThat(expected) .hasMessageThat() .isEqualTo("I bet you didn't think Thread.interrupt could throw"); /*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
} }; Thread runner = new Thread(task); runner.start(); isInterruptibleRegistered.await(); RuntimeException expected = assertThrows(RuntimeException.class, task::interruptTask); assertThat(expected) .hasMessageThat() .isEqualTo("I bet you didn't think Thread.interrupt could throw"); /*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/TrustedListenableFutureTask.java
} @Override protected void afterDone() { super.afterDone(); if (wasInterrupted()) { InterruptibleTask<?> localTask = task; if (localTask != null) { localTask.interruptTask(); } } this.task = null; } @Override protected @Nullable String pendingToString() { InterruptibleTask<?> localTask = task; if (localTask != null) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0)