- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 151 for Future (0.22 sec)
-
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Implementation of {@code Futures#withTimeout}. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java
static final Future<String> FAILED_FUTURE_OTHER_THROWABLE = immediateFailedFuture(OTHER_THROWABLE); static final Error ERROR = new Error("mymessage"); static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR); static final Future<String> RUNTIME_EXCEPTION_FUTURE = UncheckedThrowingFuture.throwingRuntimeException(RUNTIME_EXCEPTION);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 13:46:56 GMT 2023 - 6.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} } /** Checks that future.get times out, with the default timeout of {@code timeoutMillis()}. */ void assertFutureTimesOut(Future<?> future) { assertFutureTimesOut(future, timeoutMillis()); } /** Checks that future.get times out, with the given millisecond timeout. */ void assertFutureTimesOut(Future<?> future, long timeoutMillis) { long startTime = System.nanoTime();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
return i; } }; List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); for (int i = 0; i < 10; i++) { Future<Integer> future = futures.get(i); assertTrue("Task should have been run before being returned", future.isDone()); assertEquals(i, future.get().intValue()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
/** * Contains the most recently submitted {@code Future}, which may be cancelled or updated, * always under a lock. */ private static final class SupplantableFuture implements Cancellable { private final ReentrantLock lock; @GuardedBy("lock") private Future<@Nullable Void> currentFuture; SupplantableFuture(ReentrantLock lock, Future<@Nullable Void> currentFuture) { this.lock = lock;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isCancelled()); ExecutorService executor = Executors.newSingleThreadExecutor(); try { Future<Boolean> getResult = executor.submit(() -> future.get()); // Release the future value. latch.countDown(); assertTrue(getResult.get(10, SECONDS)); } finally { executor.shutdownNow(); } assertTrue(future.isDone());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
guava/src/com/google/common/base/Predicate.java
* Otherwise, at least reduce <i>explicit</i> dependencies on this type by using lambda expressions * or method references instead of classes, leaving your code easier to migrate in the future. * * <p>The {@link Predicates} class provides common predicates and related utilities. * * <p>See the Guava User Guide article on <a
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 3.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
} /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting */ @SuppressWarnings("removal") // b/260137033 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
super.releaseResources(reason); /* * If the output future is done, then it won't need to interrupt the task later, so it can clear * its reference to it. * * If the output future is *not* done, then the task field will be cleared after the task runs * or after the output future is done, whichever comes first. */ if (reason == OUTPUT_FUTURE_DONE) { this.task = null; } } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
return taskDone; } }; List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, TimeUnit.MILLISECONDS); Future<Boolean> future = futureList.get(0); assertFalse(taskDone); assertTrue(future.isDone()); assertThrows(CancellationException.class, () -> future.get()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0)