Searched defs:completionService (Results 1 - 2 of 2) sorted by relevance

/forgerock/openidm-v4/openidm-core/src/main/java/org/forgerock/openidm/sync/impl/
H A DReconFeeder.java50 CompletionService<Void> completionService; field in class:ReconFeeder
80 completionService = new ExecutorCompletionService<Void>(executor);
90 Future<Void> future = completionService.take();
107 completionService.submit(createTask(entry));
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java1236 final CompletionService<V> completionService = new ExecutorCompletionService<>(executor);
1239 completionService.submit(task);
1241 return waitTasksTermination(completionService, tasks.size());
2645 private static <K> List<K> waitTasksTermination(CompletionService<K> completionService, int nbTasks) argument
2651 results.add(completionService.take().get());

Completed in 43 milliseconds