- Sort Score
- Num 10 results
- Language All
Results 11 - 13 of 13 for invokeAll (0.07 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
List<Future<String>> results; results = service.invokeAll(callables); assertThat(getOnlyElement(results)).isInstanceOf(TrustedListenableFutureTask.class); results = service.invokeAll(callables, 1, SECONDS); assertThat(getOnlyElement(results)).isInstanceOf(TrustedListenableFutureTask.class); /*
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Dec 12 00:25:21 GMT 2025 - 26.5K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
new Callable<Boolean>() { @Override public Boolean call() { 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()); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 18 22:10:29 GMT 2024 - 3.7K bytes - Click Count (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
new Callable<Boolean>() { @Override public Boolean call() { 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()); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 18 22:10:29 GMT 2024 - 3.7K bytes - Click Count (0)