- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for interruptTask (0.49 seconds)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
/** * Any interruption that happens as a result of calling interruptTask will arrive before this * method is called. Complete Futures here. */ abstract void afterRanInterruptiblySuccess(@ParametricNullness T result); /** * Any interruption that happens as a result of calling interruptTask will arrive before this * method is called. Complete Futures here. */
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/AbstractFuture.java
future.releaseWaiters(); /* * We call interruptTask() immediately before afterDone() so that migrating between the two * can be a no-op. */ if (callInterruptTask) { future.interruptTask(); /* * Interruption doesn't propagate through a DelegatingToFuture chain (see getFutureValue), * so don't invoke interruptTask on any subsequent futures. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.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-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} } private static final class InterruptibleFuture extends AbstractFuture<String> { boolean interruptTaskWasCalled; @Override protected void interruptTask() { assertFalse(interruptTaskWasCalled); interruptTaskWasCalled = true; } } private static boolean isWindows() { return OS_NAME.value().startsWith("Windows"); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} } private static final class InterruptibleFuture extends AbstractFuture<String> { boolean interruptTaskWasCalled; @Override protected void interruptTask() { assertFalse(interruptTaskWasCalled); interruptTaskWasCalled = true; } } private static boolean isWindows() { return OS_NAME.value().startsWith("Windows"); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0)