- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Interruption (0.08 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
@ParametricNullness abstract T runInterruptibly() throws Exception; /** * 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 10.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/InterruptibleTask.java
@ParametricNullness abstract T runInterruptibly() throws Exception; /** * 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
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/collect/Queues.java
* different behavior in case it is interrupted while waiting. In that case, the operation will * continue as usual, and in the end the thread's interruption status will be set (no {@code * InterruptedException} is thrown). * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
Fire(TimeoutFuture<V> timeoutFuture) { this.timeoutFutureRef = timeoutFuture; } @Override // TODO: b/227335009 - Maybe change interruption behavior, but it requires thought. @SuppressWarnings("Interruption") public void run() { // If either of these reads return null then we must be after a successful cancel or another // call to this method.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 8.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} executionList.execute(); if (mayInterruptIfRunning) { interruptTask(); } return true; } /** * Subclasses can override this method to implement interruption of the future's computation. * The method is invoked automatically by a successful call to {@link #cancel(boolean) * cancel(true)}. * * <p>The default implementation does nothing. *
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/src/com/google/common/collect/Queues.java
* different behavior in case it is interrupted while waiting. In that case, the operation will * continue as usual, and in the end the thread's interruption status will be set (no {@code * InterruptedException} is thrown). * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
assertThat(Thread.currentThread().isInterrupted()).isFalse(); } }); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * <ol> * <li>execution will not stop until the task queue is empty. * <li>tasks will begin execution with the thread marked as not interrupted - any interruption * applies only to the task that was running at the point of interruption. * <li>if the thread was interrupted before the SequentialExecutor's worker begins execution,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 44.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
assertThat(Thread.currentThread().isInterrupted()).isFalse(); } }); // Run those tasks together. fakePool.runAll(); // Check that the interruption of a SequentialExecutor's task is restored to the thread once // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other // test case. assertThat(Thread.interrupted()).isTrue();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
private final Future<?> delegate; FutureAsCancellable(Future<?> delegate) { this.delegate = delegate; } @Override @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller. public void cancel(boolean mayInterruptIfRunning) { delegate.cancel(mayInterruptIfRunning); } @Override public boolean isCancelled() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 16:22:21 UTC 2024 - 27.8K bytes - Viewed (0)