- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 728 for futures (0.06 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
} @Override public <T> Future<T> submit(Callable<T> task) { throw new UnsupportedOperationException(); } @Override public Future<?> submit(Runnable task) { throw new UnsupportedOperationException(); } @Override public <T> Future<T> submit(Runnable task, T result) { throw new UnsupportedOperationException(); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
/** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS); } catch (TimeoutException e) {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.7K bytes - Viewed (0) -
android/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()); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
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()); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
return new ExecutionListWrapper() { final AbstractFuture<?> future = new AbstractFuture<Object>() {}; @Override public void add(Runnable runnable, Executor executor) { future.addListener(runnable, executor); } @Override public void execute() { future.set(null); }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 15.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20)); @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20)); @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Nov 04 17:24:58 UTC 2025 - 12.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultimapKeysTester.java
import static com.google.common.collect.testing.features.CollectionFeature.SUPPORTS_ITERATOR_REMOVE; import static com.google.common.collect.testing.features.CollectionSize.ONE; import static com.google.common.collect.testing.features.CollectionSize.SEVERAL; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_KEYS; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_KEY_QUERIES;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 4.3K bytes - Viewed (1) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultimapContainsEntryTester.java
import static com.google.common.collect.testing.features.CollectionSize.ZERO; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_KEYS; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_KEY_QUERIES; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_VALUES; import static com.google.common.collect.testing.features.MapFeature.ALLOWS_NULL_VALUE_QUERIES;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 3.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionSpliteratorTester.java
import static com.google.common.collect.testing.features.CollectionFeature.ALLOWS_NULL_VALUES; import static com.google.common.collect.testing.features.CollectionFeature.KNOWN_ORDER; import static com.google.common.collect.testing.features.CollectionFeature.SUPPORTS_ADD; import static com.google.common.collect.testing.features.CollectionFeature.SUPPORTS_REMOVE; import static com.google.common.collect.testing.features.CollectionSize.ZERO;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
// return responseData; // } // } // return null; // } // }); // } // List<Future<ResponseData>> futureList = executorService.invokeAll(list); // for (Future<ResponseData> future : futureList) { // ResponseData responseData = future.get(); // if (responseData != null) { // System.out.println("status: " // + responseData.getHttpStatusCode()Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 11.7K bytes - Viewed (0)