- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 80 for isDone (0.05 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// Why 1000? WHY NOT! private static final int MAX_BUSY_WAIT_SPINS = 1000; @Override public final void run() { /* * Set runner thread before checking isDone(). If we were to check isDone() first, the task * might be cancelled before we set the runner thread. That would make it impossible to * interrupt, yet it will still run, since interruptTask will leave the runner value null,
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/ForwardingFluentFuture.java
return delegate.cancel(mayInterruptIfRunning); } @Override public boolean isCancelled() { return delegate.isCancelled(); } @Override public boolean isDone() { return delegate.isDone(); } @Override @ParametricNullness public V get() throws InterruptedException, ExecutionException { return delegate.get(); } @Override @ParametricNullness
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 2.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
} public void testCancel_notDoneNoInterrupt() throws Exception { Future<?> future = newFutureInstance(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertNull(tryInternalFastPathGetFailure(future)); CancellationException e = assertThrows(CancellationException.class, () -> future.get()); assertNotNull(e.getCause()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
} public void testCancel_notDoneNoInterrupt() throws Exception { Future<?> future = newFutureInstance(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertNull(tryInternalFastPathGetFailure(future)); CancellationException e = assertThrows(CancellationException.class, () -> future.get()); assertNotNull(e.getCause()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// Why 1000? WHY NOT! private static final int MAX_BUSY_WAIT_SPINS = 1000; @Override public final void run() { /* * Set runner thread before checking isDone(). If we were to check isDone() first, the task * might be cancelled before we set the runner thread. That would make it impossible to * interrupt, yet it will still run, since interruptTask will leave the runner value null,
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-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertThat(future.isDone()).isFalse(); assertThat(future.set(1)).isTrue(); assertSuccessful(future, 1); } public void testSetFutureNull() throws Exception { assertThrows(NullPointerException.class, () -> future.setFuture(null)); assertThat(future.isDone()).isFalse(); assertThat(future.set(1)).isTrue(); assertSuccessful(future, 1);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 15.5K bytes - Viewed (0) -
guava/src/com/google/common/hash/Murmur3_32HashFunction.java
private int h1; private long buffer; private int shift; private int length; private boolean isDone; Murmur3_32Hasher(int seed) { this.h1 = seed; this.length = 0; isDone = false; } private void update(int nBytes, long update) { // 1 <= nBytes <= 4 buffer |= (update & 0xFFFFFFFFL) << shift;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Aug 02 13:50:22 UTC 2024 - 11.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java
return delegate.cancel(mayInterruptIfRunning); } @Override public boolean isCancelled() { return delegate.isCancelled(); } @Override public boolean isDone() { return delegate.isDone(); } @Override @ParametricNullness public V get() throws InterruptedException, ExecutionException { return delegate.get(); } @Override @ParametricNullness
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
* returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an * internal, unbounded pool at the first call to {@code addListener} and holding it until the * future is {@linkplain Future#isDone() done}. * * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link * MoreExecutors#listeningDecorator( java.util.concurrent.ExecutorService)}, {@link
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
*/ @CanIgnoreReturnValue @Override public V get() throws InterruptedException, ExecutionException { return sync.get(); } @Override public boolean isDone() { return sync.isDone(); } @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0)