- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for interruptTask (0.08 sec)
-
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. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 10.1K bytes - Viewed (0) -
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. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 10.1K bytes - Viewed (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");
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.6K bytes - Viewed (0) -
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();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 08 20:30:27 UTC 2022 - 1.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
// TODO(lukes): consider adding the StackOverflowError protection from the server version delegate.cancel(mayInterruptIfRunning); } return true; } protected void interruptTask() {} @Override public boolean isCancelled() { return state.isCancelled(); } @Override public boolean isDone() { return state.isDone(); } /*
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (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"); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0)