summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
87be585)
Change-Id: I2452717e6141c1380d244bd66181440e249e21ad
Signed-off-by: Illia <illia.ihushev@pantheon.tech>
import com.google.common.collect.MultimapBuilder;
import com.google.common.collect.Table;
import com.google.common.collect.Table.Cell;
import com.google.common.collect.MultimapBuilder;
import com.google.common.collect.Table;
import com.google.common.collect.Table.Cell;
-import com.google.common.util.concurrent.ListeningExecutorService;
-import com.google.common.util.concurrent.MoreExecutors;
import java.io.BufferedWriter;
import java.io.File;
import java.io.IOException;
import java.io.BufferedWriter;
import java.io.File;
import java.io.IOException;
import java.util.Optional;
import java.util.ServiceLoader;
import java.util.Set;
import java.util.Optional;
import java.util.ServiceLoader;
import java.util.Set;
-import java.util.concurrent.ForkJoinPool;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collectors;
LOG.debug("Parent directories created in {}", sw);
// Step four: submit all code generation tasks (via parallelStream()) and wait for them to complete
LOG.debug("Parent directories created in {}", sw);
// Step four: submit all code generation tasks (via parallelStream()) and wait for them to complete
- final ListeningExecutorService service = MoreExecutors.listeningDecorator(ForkJoinPool.commonPool());
sw.reset().start();
final List<File> result = dirs.values().parallelStream()
.map(GenerationTask::generateFile)
sw.reset().start();
final List<File> result = dirs.values().parallelStream()
.map(GenerationTask::generateFile)