- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 154 for itNone (0.24 sec)
-
guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
TrustedFutureInterruptibleTask(Callable<V> callable) { this.callable = checkNotNull(callable); } @Override final boolean isDone() { return TrustedListenableFutureTask.this.isDone(); } @Override @ParametricNullness V runInterruptibly() throws Exception { return callable.call(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class); assertTrue(runnableFuture.isDone()); assertTrue(runnable.run); ListenableFuture<String> callableFuture = e.submit(new TestCallable()); assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class); assertTrue(callableFuture.isDone()); assertEquals("foo", callableFuture.get()); TestRunnable runnable2 = new TestRunnable();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class); assertTrue(runnableFuture.isDone()); assertTrue(runnable.run); ListenableFuture<String> callableFuture = e.submit(new TestCallable()); assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class); assertTrue(callableFuture.isDone()); assertEquals("foo", callableFuture.get()); TestRunnable runnable2 = new TestRunnable();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java
@ElementTypesAreNonnullByDefault abstract class InterruptibleTask<T extends @Nullable Object> implements Runnable { @Override public void run() { T result = null; Throwable error = null; if (isDone()) { return; } try { result = runInterruptibly(); } catch (Throwable t) { error = t; } if (error == null) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 08 20:30:27 UTC 2022 - 1.6K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object x = new Object() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object x = new Object() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
if (!future.isDone()) { errorMessage.set("Set call exited before future was complete."); } } }); executor.execute( new Runnable() { @Override public void run() { future.setException(new IllegalArgumentException("failure")); if (!future.isDone()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K 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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
if (!future.isDone()) { errorMessage.set("Set call exited before future was complete."); } } }); executor.execute( new Runnable() { @Override public void run() { future.setException(new IllegalArgumentException("failure")); if (!future.isDone()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K 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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0)