- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 354 for Futures (0.04 seconds)
-
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
taskDone = true; return taskDone; } }; List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, MILLISECONDS); Future<Boolean> future = futureList.get(0); assertFalse(taskDone); assertTrue(future.isDone()); assertThrows(CancellationException.class, () -> future.get()); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 18 22:10:29 GMT 2024 - 3.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate().submit(task); } @Override public Future<?> submit(Runnable task) { return delegate().submit(task); } @Override public <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.1K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Platform.java
static <V extends @Nullable Object> V get(AbstractFuture<V> future) throws InterruptedException, ExecutionException { return future.getFromAlreadyDoneTrustedFuture(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { checkNotNull(unit); return future.getFromAlreadyDoneTrustedFuture(); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 27 16:15:49 GMT 2025 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt
* share the same [Address] may share a [Connection]. This class implements the policy * of which connections to keep open for future use. * * @constructor Create a new connection pool with tuning parameters appropriate for a single-user * application. The tuning parameters in this pool are subject to change in future OkHttp releases. * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of * inactivity. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 3.4K bytes - Click Count (0) -
impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/CompletionServiceStub.java
} @Override public Future<ProjectSegment> take() throws InterruptedException { return null; } @Override public Future<ProjectSegment> poll() { return null; } @Override public Future<ProjectSegment> poll(long timeout, TimeUnit unit) throws InterruptedException { return null; }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 2.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
CountDownLatch latch = new CountDownLatch(1); SettableFuture<?> future = SettableFuture.create(); Executor delegate = new Executor() { @Override public void execute(Runnable task) { if (future.set(null)) { awaitUninterruptibly(latch); } throw new RejectedExecutionException();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 11.4K bytes - Click Count (0) -
docs/fr/docs/help-fastapi.md
## Aider les autres à résoudre les problèmes dans GitHub Vous pouvez voir <a href="https://github.com/fastapi/fastapi/issues" class="external-link" target="_blank">les problèmes existants</a> et essayer d'aider les autres, la plupart du temps il s'agit de questions dont vous connaissez peut-être déjà la réponse. 🤓 ## Watch le dépôt GitHub
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 10:49:48 GMT 2025 - 5.7K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate().submit(task); } @Override public Future<?> submit(Runnable task) { return delegate().submit(task); } @Override public <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.1K bytes - Click Count (0) -
impl/maven-core/src/site/apt/inheritance.apt
+-----+ <project> <modelVersion>4.0.0</modelVersion> <parent> <groupId></groupId> <artifactId></artifactId> <version></version> </parent> </project> +-----+ Extending the POM in the future In order to anticipate changes in the structure of the POM as new releases of maven occur, the maven inheritance model must be pinned against a particular
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Platform.java
} } static <V extends @Nullable Object> V get(AbstractFuture<V> future) throws InterruptedException, ExecutionException { return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return future.blockingGet(timeout, unit); } private Platform() {}
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0)