- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Future (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
* * <p>Cancelling a delegate future propagates to input futures once all the delegates complete, * either from cancellation or because an input future has completed. If N futures are passed in, * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of * the input futures complete. If all the delegates are cancelled, all the input futures will be
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** * Sets the result of this {@code Future} to match the supplied input {@code Future} once the * supplied {@code Future} is done, unless this {@code Future} has already been cancelled or set * (including "set asynchronously," defined below). * * <p>If the supplied future is {@linkplain #isDone done} when this method is called and the call
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} void assertThatFutureFailsWithException(Future<?> future) { try { getUninterruptibly(future); fail("Expected future to fail: " + future); } catch (ExecutionException e) { assertThat(e).hasCauseThat().isSameInstanceAs(exception); } } static void assertThatFutureBecomesCancelled(Future<?> future) throws ExecutionException { try {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} void assertThatFutureFailsWithException(Future<?> future) { try { getUninterruptibly(future); fail("Expected future to fail: " + future); } catch (ExecutionException e) { assertThat(e).hasCauseThat().isSameInstanceAs(exception); } } static void assertThatFutureBecomesCancelled(Future<?> future) throws ExecutionException { try {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* AsyncCacheLoader.asyncLoad}</a> must return a {@code CompletableFuture}. Users of Guava's {@link * com.google.common.util.concurrent.ListenableFuture} can adapt between the two {@code Future} * types by using <a href="https://github.com/lukas-krecan/future-converter#java8-guava">{@code * net.javacrumbs.futureconverter.java8guava.FutureConverter}</a>. * * <h2>More on {@code CacheBuilder}</h2> *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
.collect(Collectors.toList()); try { List<Future<InterimResult>> futures = executor.invokeAll(tasks); List<InterimResult> list = new ArrayList<>(); for (Future<InterimResult> future : futures) { InterimResult interimResult = future.get(); list.add(interimResult); } return list;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
* asList}{@code (...))}, or for creating an empty set then calling {@link Collections#addAll}. * This method is not actually very useful and will likely be deprecated in the future. */ @SuppressWarnings("nullness") // TODO: b/316358623 - Remove after checker fix. public static <E extends @Nullable Object> HashSet<E> newHashSet(E... elements) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 77.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* if you are writing a application that needs to aggressively release unused resources you may do * so. * * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will * also cause future calls to the client to be rejected. * * ```java * client.dispatcher().executorService().shutdown(); * ``` * * Clear the connection pool with [evictAll()][ConnectionPool.evictAll]. Note that the connection
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
src/bytes/bytes_test.go
} func TestSplit(t *testing.T) { for _, tt := range splittests { a := SplitN([]byte(tt.s), []byte(tt.sep), tt.n) // Appending to the results should not change future results. var x []byte for _, v := range a { x = append(v, 'z') } result := sliceOfString(a) if !eq(result, tt.a) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 24 16:07:25 GMT 2024 - 56.2K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrPastObjectLockRetainDate: { Code: "InvalidRequest", Description: "the retain until date must be in the future", HTTPStatusCode: http.StatusBadRequest, }, ErrUnknownWORMModeDirective: { Code: "InvalidRequest", Description: "unknown wormMode directive", HTTPStatusCode: http.StatusBadRequest,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6)