В университете дали задание, написать поискового робота, с помощью ExecutorServise, а доступ к единому индексу должен получаться с помощью Future<>. И я не могу никак додумать, что я должен сделать чтобы выполнить данное условие
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.nio.file.*;
import java.util.*;
import java.util.concurrent.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
public class Main {
public static void main(String[] args) throws IOException, InterruptedException, ExecutionException {
Path dir = FileSystems.getDefault().getPath("src\\package\\");
Map<String, List<String>> result = new HashMap<>();
ExecutorService executor = Executors.newFixedThreadPool(8);
try (DirectoryStream<Path> stream = Files.newDirectoryStream(dir, "*.java")) {
for (Path path : stream) {
CountDownLatch countDownLatch = new CountDownLatch(1);
executor.execute(() -> {
try {
synchronized (result) {
countDownLatch.countDown();
String string = Files.lines(Paths.get("src\\package\\" + path.getFileName()), StandardCharsets.UTF_8)
.collect(Collectors.joining());
String regex = "class\\s+(?<class>\\w+)\\s+(extends\\s+(?<extends>\\w+))?";
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(string);
if (matcher.find()) {
String child = matcher.group("class");
String parent = matcher.group("extends");
List<String> children = result.getOrDefault(parent, new ArrayList<>());
children.addAll(Collections.singleton(child));
result.put(parent, children);
}
}
} catch (IOException e) {
e.printStackTrace();
}
});
countDownLatch.await();
}
}
executor.shutdown();
executor.awaitTermination(10, TimeUnit.MINUTES);
result.forEach((k, v) -> System.out.println(k + ": " + v));
}
}
Вот собственно, сам код, джаве только учусь, поэтому не судите строго. Буду благодарен за любую помощь.
CountDownLatch
не нужен.synchronized (result
делает твой код однопоточным. В старом варианте был синхронизованный Map и это было правильно.getOrDefault + put
наcomputeIfAbsent
, но ты этого так и не сделал.