- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for testInvokeAll (0.06 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
assertThat(recordedTasks).isSameInstanceAs(tasks); assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS); assertThat(Duration.ofNanos(recordedTimeout)).isEqualTo(Duration.ofSeconds(7)); } public void testInvokeAll() throws Exception { Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAll"); List<Future<String>> result = executorService.invokeAll(tasks, Duration.ofDays(365));
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
Future<String> f = testExecutor.submit(task); mock.assertLastMethodCalled("submit"); assertThat(f.get()).isEqualTo(RESULT_VALUE); } } public void testInvokeAll() throws InterruptedException, ExecutionException { List<Callable<String>> tasks = createTasks(3); { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
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
Future<String> f = testExecutor.submit(task); mock.assertLastMethodCalled("submit"); assertThat(f.get()).isEqualTo(RESULT_VALUE); } } public void testInvokeAll() throws InterruptedException, ExecutionException { List<Callable<String>> tasks = createTasks(3); { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
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)