- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for testInvokeAny (0.07 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
private long recordedTimeout; private TimeUnit recordedTimeUnit; private final ListeningExecutorService executorService = new FakeExecutorService(); public void testInvokeAny() throws Exception { Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAny"); String result = executorService.invokeAny(tasks, Duration.ofSeconds(7)); assertThat(result).isEqualTo("invokeAny");
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 4.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); mock.assertMethodWithTimeout("invokeAll", timeout, unit); checkResults(futures); } } public void testInvokeAny() throws InterruptedException, ExecutionException, TimeoutException { List<Callable<String>> tasks = createTasks(3); { MockExecutor mock = new MockExecutor();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); mock.assertMethodWithTimeout("invokeAll", timeout, unit); checkResults(futures); } } public void testInvokeAny() throws InterruptedException, ExecutionException, TimeoutException { List<Callable<String>> tasks = createTasks(3); { MockExecutor mock = new MockExecutor();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0)