- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 354 for Futures (0.09 seconds)
-
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) -
android/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; }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 11.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java
@NullUnmarked public class TrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() { AbstractFuture<Integer> future = new TrustedFuture<Integer>() {}; assertTrue(future instanceof TrustedFuture); // sanity check return future; }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 1.2K bytes - Click Count (0) -
PULL_REQUESTS_ETIQUETTE.md
fostering efficient reviews and robust code. ## Why Pull Requests? Pull Requests (PRs) drive quality in MinIO’s codebase by: - Enabling peer review without pair programming. - Documenting changes for future reference. - Ensuring commits tell a clear story of development. **A poor commit lasts forever, even if code is refactored.** ## Crafting a Quality PR A strong MinIO PR:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun May 25 16:32:03 GMT 2025 - 4.7K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.submit(task); } @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException { Preconditions.checkNotNull(tasks, "tasks must not be null!"); return delegate.invokeAll(tasks); } @Override public <T> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.submit(task); } @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException { Preconditions.checkNotNull(tasks, "tasks must not be null!"); return delegate.invokeAll(tasks); } @Override public <T> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
build-logic/integration-testing-kotlin/src/main/kotlin/gradlebuild.kotlin-dsl-plugin-bundle-integ-tests.gradle.kts
} } dependencies { integTestRuntimeOnly(project(":kotlin-dsl-plugins")) { because("Tests require 'future-plugin-versions.properties' on the test classpath and the embedded executer needs them available") attributes { attribute(LibraryElements.LIBRARY_ELEMENTS_ATTRIBUTE, objects.named("future-versions-resource")) } } integTestLocalRepository(project(":kotlin-dsl-plugins"))Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Dec 30 14:53:14 GMT 2024 - 756 bytes - Click Count (0) -
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
import java.net.InetSocketAddress import java.net.ServerSocket import java.security.PrivateKey import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.concurrent.Future import javax.net.ServerSocketFactory import javax.net.SocketFactory import javax.net.ssl.SSLSocket import okhttp3.Handshake import okhttp3.Handshake.Companion.handshake import okhttp3.TestUtil.threadFactory
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 7.2K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java
// don't stop processing in case a future segment explicitly excludes this repo } // check for external:http:* else if (EXTERNAL_HTTP_WILDCARD.equals(repo) && isExternalHttpRepo(originalRepository)) { result = true; // don't stop processing in case a future segment explicitly excludes this repo
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java
import java.util.concurrent.Executor; import org.jspecify.annotations.Nullable; /** * A {@link ListenableFuture} which forwards all its method calls to another future. Subclasses * should override one or more methods to modify the behavior of the backing future as desired per * the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>. * * <p>Most subclasses can just use {@link SimpleForwardingListenableFuture}.Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0)