Searched defs:futures (Results 1 – 10 of 10) sorted by relevance
46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny() local124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local156 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
40 Iterable<? extends ListenableFuture<?>> futures) { in combine()
100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local135 private static void checkResults(List<Future<String>> futures) in checkResults()
154 List<Future<Integer>> futures = in testDirectExecutorServiceInvokeAll() local266 List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
59 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove() local
284 Iterable<? extends ListenableFuture<? extends T>> futures) { in inCompletionOrder()
270 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
678 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
1150 def __init__(self, *futures):