- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for restore (0.16 sec)
-
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* * <p>If the Thread in use is interrupted before or during execution of the tasks in {@link * #queue}, the Executor will complete its tasks, and then restore the interruption. This means * that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/RangeTest.java
.addEqualityGroup(Range.all(), Range.all()) .addEqualityGroup("Phil") .testEquals(); } @GwtIncompatible // TODO(b/148207871): Restore once Eclipse compiler no longer flakes for this. public void testLegacyComparable() { Range<LegacyComparable> range = Range.closed(LegacyComparable.X, LegacyComparable.Y); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 24.1K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/DirectedGraphConnections.java
addedPredecessor = true; } else if (previousValue instanceof PredAndSucc) { // Restore previous PredAndSucc object. adjacentNodeValues.put(node, previousValue); addedPredecessor = false; } else if (previousValue != PRED) { // successor // Do NOT use method parameter value 'unused'. In directed graphs, successors store the value. adjacentNodeValues.put(node, new PredAndSucc(previousValue));
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 18K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/RangeTest.java
.addEqualityGroup(Range.all(), Range.all()) .addEqualityGroup("Phil") .testEquals(); } @GwtIncompatible // TODO(b/148207871): Restore once Eclipse compiler no longer flakes for this. public void testLegacyComparable() { Range<LegacyComparable> range = Range.closed(LegacyComparable.X, LegacyComparable.Y); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 24.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
* roughly) 2.5s longer. (2.5s is also the maximum length of time we will wait for a timed get * that is expected to succeed; the fact that the numbers match is only a coincidence.) See the * comment below for how to restore the fast but hang-y version. */ @J2ktIncompatible @GwtIncompatible // used only in GwtIncompatible tests private static List<String> conditionalPseudoTimedGetUninterruptibly( TestFutureBatch inputs,
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
* roughly) 2.5s longer. (2.5s is also the maximum length of time we will wait for a timed get * that is expected to succeed; the fact that the numbers match is only a coincidence.) See the * comment below for how to restore the fast but hang-y version. */ @J2ktIncompatible @GwtIncompatible // used only in GwtIncompatible tests private static List<String> conditionalPseudoTimedGetUninterruptibly( TestFutureBatch inputs,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
pred.next = succ; if (pred.thread == null) { // We raced with another node that unlinked pred. Restart. continue restart; } } else if (!ATOMIC_HELPER.casWaiters(this, curr, succ)) { // We are unlinking head continue restart; // We raced with an add or complete } curr = succ; } break; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }); // 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(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* 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, * the interrupt will be restored to the thread after it completes so that its {@code * delegate} Executor may process the interrupt. * <li>subtasks are run with the thread uninterrupted and interrupts received during execution
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* ExecutionError} (if the cause is an {@code Error}). * <li>Any {@link InterruptedException} causes a retry of the {@code get} call. The interrupt is * restored before {@code getUnchecked} returns. * <li>Any {@link CancellationException} is propagated untouched. So is any other {@link * RuntimeException} ({@code get} implementations are discouraged from throwing such
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0)