- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 73 for isHoge (0.08 seconds)
-
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
protected void finalize() { future.set(null); } }; unused = null; // Hint to the JIT that unused is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_future_cancel() { SettableFuture<@Nullable Void> future = SettableFuture.create(); Object unused = new Object() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFuture.java
return delegate().cancel(mayInterruptIfRunning); } @Override public boolean isCancelled() { return delegate().isCancelled(); } @Override public boolean isDone() { return delegate().isDone(); } @Override @CanIgnoreReturnValue @ParametricNullness public V get() throws InterruptedException, ExecutionException { return delegate().get(); } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 3.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
isInterruptibleRegistered.countDown(); new CountDownLatch(1).await(); // the interrupt will wake us up return "impossible!"; } @Override boolean isDone() { return false; } @Override String toPendingString() { return ""; } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
isInterruptibleRegistered.countDown(); new CountDownLatch(1).await(); // the interrupt will wake us up return "impossible!"; } @Override boolean isDone() { return false; } @Override String toPendingString() { return ""; } @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown(); assertThat(executor.awaitTermination(10, SECONDS)).isTrue();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
import org.jspecify.annotations.Nullable; /** * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and * it is invoked using this executor once the future's computation is {@linkplain Future#isDone() * complete}. If the computation has already completed when the listener is added, the listener will * execute immediately. * * <p>See the Guava User Guide article on <aCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
} @Override public boolean isCancelled() { return input.isCancelled(); } @Override public boolean isDone() { return input.isDone(); } @Override public O get() throws InterruptedException, ExecutionException { return applyTransformation(input.get()); } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
import org.jspecify.annotations.Nullable; /** * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and * it is invoked using this executor once the future's computation is {@linkplain Future#isDone() * complete}. If the computation has already completed when the listener is added, the listener will * execute immediately. * * <p>See the Guava User Guide article on <aCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown(); assertThat(executor.awaitTermination(10, SECONDS)).isTrue();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
CombinedFutureInterruptibleTask(Executor listenerExecutor) { this.listenerExecutor = checkNotNull(listenerExecutor); } @Override final boolean isDone() { return CombinedFuture.this.isDone(); } final void execute() { try { listenerExecutor.execute(this); } catch (RejectedExecutionException e) { CombinedFuture.this.setException(e);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.8K bytes - Click Count (0)