Searched refs:futures (Results 1 – 1 of 1) sorted by relevance
80 final Set<Future<Void>> futures = new HashSet<>(); in threadedWrites() local82 futures.add(completionService.submit(callable)); in threadedWrites()85 while (futures.size() > 0) { in threadedWrites()87 futures.remove(future); in threadedWrites()92 for (final Future<Void> f : futures) { in threadedWrites()